package async_rpc_kernel

  1. Overview
  2. Docs
package async_rpc_kernel
Legend:
Library
Module
Module type
Parameter
Class
Class type
type ('a, 'b) result_mode = ('a, 'b) Implementation_types.Implementation.F.result_mode =
  1. | Blocking : ('a, 'a) result_mode
  2. | Deferred : ('a, 'a Async_kernel.Deferred.t) result_mode
type ('connection_state, 'query, 'init, 'update) streaming_impl = ('connection_state, 'query, 'init, 'update) Implementation_types.Implementation.F.streaming_impl =
  1. | Pipe of 'connection_state -> 'query -> ('init * 'update Async_kernel.Pipe.Reader.t, 'init) Core_kernel.Result.t Async_kernel.Deferred.t
  2. | Direct of 'connection_state -> 'query -> 'update Implementation_types.Direct_stream_writer.t -> ('init, 'init) Core_kernel.Result.t Async_kernel.Deferred.t
type 'connection_state t = 'connection_state Implementation_types.Implementation.F.t =
  1. | One_way : 'msg Core_kernel.Bin_prot.Type_class.reader * ('connection_state -> 'msg -> unit) -> 'connection_state t
  2. | One_way_expert : ('connection_state -> Core_kernel.Bigstring.t -> pos:int -> len:int -> unit) -> 'connection_state t
  3. | Rpc : 'query Core_kernel.Bin_prot.Type_class.reader * 'response Core_kernel.Bin_prot.Type_class.writer * ('connection_state -> 'query -> 'result) * ('response, 'result) result_mode -> 'connection_state t
  4. | Rpc_expert : ('connection_state -> Expert.Responder.t -> Core_kernel.Bigstring.t -> pos:int -> len:int -> 'result) * (Expert.implementation_result, 'result) result_mode -> 'connection_state t
  5. | Streaming_rpc : 'query Core_kernel.Bin_prot.Type_class.reader * 'init Core_kernel.Bin_prot.Type_class.writer * 'update Core_kernel.Bin_prot.Type_class.writer * ('connection_state, 'query, 'init, 'update) streaming_impl -> 'connection_state t
val lift : 'a t -> f:('b -> 'a) -> 'b t