Module Async_rpc_kernel__.Implementations

Internal to Async_rpc_kernel. See Rpc.Implementations.

type 'a t

val create : implementations:'connection_state Async_rpc_kernel__.Implementation.t list ‑> on_unknown_rpc:[ `Raise | `Continue | `Close_connection | `Call of 'connection_state ‑> rpc_tag:string ‑> version:int ‑> [ `Close_connection | `Continue ] ] ‑> ('connection_state t, [ `Duplicate_implementations of Async_rpc_kernel__.Description.t list ]) Core_kernel.Result.t

val null : unit ‑> 'a t

val lift : 'a t ‑> f:('b ‑> 'a) ‑> 'b t

module Direct_stream_writer : sig ... end

module Instance : sig ... end

val instantiate : 'a t ‑> connection_description:Core_kernel.Info.t ‑> connection_close_started:Core_kernel.Info.t Async_kernel.Deferred.t ‑> connection_state:'a ‑> writer:Async_rpc_kernel__.Transport.Writer.t ‑> Instance.t

val create_exn : implementations:'connection_state Async_rpc_kernel__.Implementation.t list ‑> on_unknown_rpc:[ `Raise | `Continue | `Close_connection | `Call of 'connection_state ‑> rpc_tag:string ‑> version:int ‑> [ `Close_connection | `Continue ] ] ‑> 'connection_state t

val add : 'connection_state t ‑> 'connection_state Async_rpc_kernel__.Implementation.t ‑> 'connection_state t Core_kernel.Or_error.t

val add_exn : 'connection_state t ‑> 'connection_state Async_rpc_kernel__.Implementation.t ‑> 'connection_state t

val descriptions : _ t ‑> Async_rpc_kernel__.Description.t list

module Expert : sig ... end