Module Async_js__.Rpc.Connection

include module type of sig ... end
val sexp_of_t : t ‑> Base.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 ('rest, 'implementations) client_t = ?⁠uri:Async_js__.Ocaml_uri.Uri.t ‑> ?⁠heartbeat_config:Heartbeat_config.t ‑> ?⁠description:Core_kernel.Info.t ‑> ?⁠implementations:'implementations Client_implementations.t ‑> 'rest

This type of client connects to the websocket at the root of some host and port, i.e. ws://<address>/.

val client : (unit ‑> t Async_kernel.Deferred.Or_error.t, 's) client_t
val client_exn : (unit ‑> t Async_kernel.Deferred.t, 's) client_t