Persistent (http_client.Cohttp_backend.Client.Persistent)

type t = Persistent_connection_kernel.Make(Conn).t

val sexp_of_t : t -> Sexplib0.Sexp.t

type conn = Conn.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