package async_rpc_kernel

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
type streaming_response =
  1. | Pipe : _ Async_kernel.Pipe.Reader.t -> streaming_response
  2. | Direct : _ Direct_stream_writer.t -> streaming_response
type 'a unpacked = {
  1. implementations : 'a implementations;
  2. writer : Transport.Writer.t;
  3. open_streaming_responses : (Protocol.Query_id.t, streaming_response) Core_kernel.Hashtbl.t;
  4. mutable stopped : bool;
  5. connection_state : 'a;
  6. connection_description : Core_kernel.Info.t;
  7. mutable last_dispatched_implementation : (Description.t * 'a Implementation.F.t) option;
  8. packed_self : t;
}
and t =
  1. | T : _ unpacked -> t