Module `Async_rpc_kernel__.Implementations`

type 'a t
type 'connection_state on_unknown_rpc = [ | `Raise | `Continue | `Close_connection | `Call of 'connection_state -> rpc_tag:string -> version:int -> [ `Close_connection | `Continue ] ]

val create : implementations:'connection_state Async_rpc_kernel__.Implementation.t list -> on_unknown_rpc:'connection_state on_unknown_rpc -> ('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