package async_js

  1. Overview
  2. Docs

Module Persistent_connection.RpcSource

include Async_rpc_kernel.Persistent_connection.S with type conn = Async_js__.Rpc.Connection.t
type t
val sexp_of_t : t -> Sexplib0.Sexp.t
type conn = Rpc.Connection.t
module Event : sig ... end
val create : server_name:string -> ?on_event:('address Event.t -> unit Async_kernel.Deferred.t) -> ?retry_delay:(unit -> Core.Time_ns.Span.t) -> ?random_state:[ `Non_random | `State of Core.Random.State.t ] -> ?time_source:Async_kernel.Time_source.t -> connect:('address -> conn Core.Or_error.t Async_kernel.Deferred.t) -> address: (module Persistent_connection_kernel__Persistent_connection_kernel_intf.Address with type t = 'address) -> (unit -> 'address Core.Or_error.t Async_kernel.Deferred.t) -> t
val connected : t -> conn Async_kernel.Deferred.t
val connected_or_failed_to_connect : t -> conn Core.Or_error.t Async_kernel.Deferred.t
val current_connection : t -> conn option
val server_name : t -> string
val close : t -> unit Async_kernel.Deferred.t
val is_closed : t -> bool
val close_finished : t -> unit Async_kernel.Deferred.t
val close_when_current_connection_is_closed : t -> unit
type 'a create := server_name:string -> ?on_event:('a Event.t -> unit Async_kernel.Deferred.t) -> ?retry_delay:(unit -> Core.Time_ns.Span.t) -> ?random_state:[ `Non_random | `State of Core.Random.State.t ] -> ?time_source:Async_kernel.Time_source.t -> connect:('a -> conn Core.Or_error.t Async_kernel.Deferred.t) -> (unit -> 'a Core.Or_error.t Async_kernel.Deferred.t) -> t
Sourceval create_from_uri : Uri.t create
Sourceval create_from_uri_option : Uri.t option create