amqp-client-lwt

Amqp client library, lwt version
IN THIS PACKAGE
type t = {
active : Amqp_client_lib.Types.bit;(*

If 1, the peer starts sending content frames. If 0, the peer stops sending content frames.

*)
}
val init : active:Amqp_client_lib.Types.bit -> unit -> t
val reply : ?once:bool -> (Framing.t * Framing.channel_no) -> ( t -> Flow_ok.t Thread.Deferred.t ) -> unit Thread.Deferred.t