Up

Module Persistent_rpc_client = Async_extra.Persistent_rpc_client

Signature

module type S = sig .. end
include S with type conn = Async_extra.Rpc.Connection.t and type address = Core.Std.Host_and_port.t
val create : server_name:string -> ?log:Async_extra.Import.Log.t -> ?on_event:(Event.t -> unit) -> ?via_local_interface:Async_extra.Import.Unix.Inet_addr.t -> ?implementations:_ Async_extra.Rpc.Connection.Client_implementations.t -> ?max_message_size:int -> ?make_transport:Async_extra.Rpc.Connection.transport_maker -> ?handshake_timeout:Core.Std.Time.Span.t -> ?heartbeat_config:Async_extra.Rpc.Connection.Heartbeat_config.t -> (unit -> Core.Std.Host_and_port.t Core.Std.Or_error.t Async_extra.Import.Deferred.t) -> t

create is like the create from S, but slightly more convenient for constructing unembellished rpc connections.

module type T = sig .. end
module Make (Conn : T) : S with type conn = Conn.t and type address = Conn.Address.t