Module Coda_worker.Connection

type t = Rpc_parallel__Parallel.Make(T).Connection.t
val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t
val worker_id : t -> Id.t
val run : t -> f:( worker, 'query, 'response ) Rpc_parallel__Parallel.Function.t -> arg:'query -> 'response Core.Or_error.t Async.Deferred.t
val run_exn : t -> f:( worker, 'query, 'response ) Rpc_parallel__Parallel.Function.t -> arg:'query -> 'response Async.Deferred.t
val client : worker -> T.Connection_state.init_arg -> t Core.Or_error.t Async.Deferred.t
val client_exn : worker -> T.Connection_state.init_arg -> t Async.Deferred.t
val with_client : worker -> T.Connection_state.init_arg -> f:( t -> 'a Async.Deferred.t ) -> 'a Core.Or_error.t Async.Deferred.t
val close : t -> unit Async.Deferred.t
val close_finished : t -> unit Async.Deferred.t
val close_reason : t -> on_close:[ `finished | `started ] -> Core.Info.t Async.Deferred.t
val is_closed : t -> bool