package async_extra

  1. Overview
  2. Docs
package async_extra
Legend:
Library
Module
Module type
Parameter
Class
Class type
include S with type conn = Rpc.Connection.t and type address = Core.Host_and_port.t
type t
type address = Core.Host_and_port.t
type conn = Rpc.Connection.t
module Event : sig ... end
val connected : t -> conn Async_kernel.Deferred.t
val current_connection : t -> conn option
val close : t -> unit Async_kernel.Deferred.t
val is_closed : t -> bool
val close_finished : t -> unit Async_kernel.Deferred.t
val create : server_name:string -> ?log:Async_unix.Log.t -> ?on_event:(Event.t -> unit Async_kernel.Deferred.t) -> ?retry_delay:(unit -> Core.Time.Span.t) -> connect:(address -> conn Core.Or_error.t Async_kernel.Deferred.t) -> (unit -> address Core.Or_error.t Async_kernel.Deferred.t) -> t
val create' : server_name:string -> ?log:Async_unix.Log.t -> ?on_event:(Event.t -> unit Async_kernel.Deferred.t) -> ?retry_delay:(unit -> Core.Time.Span.t) -> ?bind_to_address:Async_unix.Unix.Inet_addr.t -> ?implementations:_ Async_rpc_kernel.Rpc.Connection.Client_implementations.t -> ?max_message_size:int -> ?make_transport:Rpc.Connection.transport_maker -> ?handshake_timeout:Core.Time.Span.t -> ?heartbeat_config:Async_rpc_kernel.Rpc.Connection.Heartbeat_config.t -> (unit -> Core.Host_and_port.t Core.Or_error.t Async_kernel.Deferred.t) -> t

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