Module Async_rpc_kernel.Implementation_types.Direct_stream_writer

module Pending_response : sig ... end

module State : sig ... end

module Id = Direct_stream_writer_id

type 'a t = {

id : Id.t;

mutable state : 'a State.t;

closed : unit Async_kernel.Ivar.t;

instance : Implementations.Instance.t;

query_id : Protocol.Query_id.t;

stream_writer : 'a Cached_stream_writer.t;

groups : 'a group_entry Core_kernel.Bag.t;

}

type 'a group_entry = {

group : 'a Direct_stream_writer.Group.t;

element_in_group : 'a t Core_kernel.Bag.Elt.t;

}

module Group : sig ... end with type a direct_stream_writer := a t