Module Async_js.Rpc.Connection

include module type of sig ... end
val sexp_of_t : t ‑> Sexplib.Sexp.t
val create : ?implementations:'s Async_rpc_kernel.Implementations.t ‑> connection_state:(t ‑> 's) ‑> ?handshake_timeout:Core_kernel.Time_ns.Span.t ‑> ?heartbeat_config:Heartbeat_config.t ‑> ?description:Core_kernel.Info.t ‑> Async_rpc_kernel.Transport.t ‑> (t, Core_kernel.Exn.t) Core_kernel.Result.t Async_kernel.Deferred.t
val contains_magic_prefix : bool Bin_prot.Type_class.reader
val description : t ‑> Core_kernel.Info.t
val add_heartbeat_callback : t ‑> (unit ‑> unit) ‑> unit
val close : ?streaming_responses_flush_timeout:Core_kernel.Time_ns.Span.t ‑> ?reason:Core_kernel.Info.t ‑> t ‑> unit Async_kernel.Deferred.t
val close_finished : t ‑> unit Async_kernel.Deferred.t
val close_reason : t ‑> on_close:[ `finished | `started ] ‑> Core_kernel.Info.t Async_kernel.Deferred.t
val is_closed : t ‑> bool
val bytes_to_write : t ‑> int
val flushed : t ‑> unit Async_kernel.Deferred.t
val with_close : ?implementations:'s Async_rpc_kernel.Implementations.t ‑> ?handshake_timeout:Core_kernel.Time_ns.Span.t ‑> ?heartbeat_config:Heartbeat_config.t ‑> connection_state:(t ‑> 's) ‑> Async_rpc_kernel.Transport.t ‑> dispatch_queries:(t ‑> 'a Async_kernel.Deferred.t) ‑> on_handshake_error:[ `Call of Core_kernel.Exn.t ‑> 'a Async_kernel.Deferred.t | `Raise ] ‑> 'a Async_kernel.Deferred.t
val server_with_close : ?handshake_timeout:Core_kernel.Time_ns.Span.t ‑> ?heartbeat_config:Heartbeat_config.t ‑> Async_rpc_kernel.Transport.t ‑> implementations:'s Async_rpc_kernel.Implementations.t ‑> connection_state:(t ‑> 's) ‑> on_handshake_error:[ `Call of Core_kernel.Exn.t ‑> unit Async_kernel.Deferred.t | `Ignore | `Raise ] ‑> unit Async_kernel.Deferred.t
type ('a, 's) client_t = ?address:Core_kernel.Host_and_port.t ‑> ?heartbeat_config:Heartbeat_config.t ‑> ?description:Core_kernel.Info.t ‑> ?implementations:'s Client_implementations.t ‑> unit ‑> 'a Async_kernel.Deferred.t
val client : (t Core_kernel.Or_error.t, 's) client_t
val client_exn : (t, 's) client_t