Module Channel.Flow_ok

Confirms to the peer that a flow command was received and processed.

type t = {
  1. active : Amqp_client_lib.Types.bit;
    (*

    Confirms the setting of the processed flow method: 1 means the peer will start sending or continue to send content frames; 0 means it will not.

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