package async_js

You can search for identifiers within the package.

in-package search v0.2.0

async_js
- Async_js
  - Debug
  - Http
    
    Method_with_args
    
    Post_body
    
    Response
    
    Response_type
  - Persistent_connection
    
    Rpc
    
    Event
  - Rpc
    
    Connection

Legend:
Library
Module
Module type
Parameter
Class
Class type

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

val create_from_uri : Uri.t create

val create_from_uri_option : Uri.t option create