Persistent (http_client.Httpaf_backend.Client.Persistent)

type conn = Conn.t

include module type of struct include Async_uri.Persistent end

type t = Async_uri.Persistent.t

val sexp_of_t : t -> Sexplib0.Sexp.t

module Event = Async_uri.Persistent.Event

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 -> Async_uri.t 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 -> Async_uri.t Async_kernel.Deferred.t

val connected_or_failed_to_connect : 
  t ->
  Async_uri.t Core.Or_error.t Async_kernel.Deferred.t

val current_connection : t -> Async_uri.t 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