Module Amqp_client_lwt.Protocol_helpers

Internal

module Protocol = Amqp_client_lib.Protocol
module Io = Amqp_client_lib.Io
type 'a post_handler = ('a -> unit) option
val bit_string : int -> int -> string
val update_property_flag : int -> (int -> 'a) -> int -> 'b
val read_property_flag : int -> int -> int
val list_create : (unit -> 'a) -> int -> 'b list
val read_method : (Amqp_client_lib.Types.message_id * ('b, 'a) Protocol.Spec.spec * 'c * 'd) -> Amqp_client_lib.Types.message_id * (once:bool -> ('a0 -> unit) -> (Framing.t * Framing.channel_no) -> unit)
val read_method_content : (Amqp_client_lib.Types.message_id * ('a, 'b) Protocol.Spec.spec * 'c * 'd) -> ((Amqp_client_lib.Types.class_id * 'e) * ('f, 'g) Protocol.Content.spec * 'h * 'i) -> Amqp_client_lib.Types.message_id * (once:bool -> (('j * ('k * string)) -> unit) -> (Framing.t * Framing.channel_no) -> unit)
val request0 : ('a -> 'b -> 'c) -> 'd -> 'e -> 'f
val reply0 : ('a * (once:bool -> ('b -> unit) -> 'c -> unit)) -> ?once:bool -> 'd -> 'e Lwt.t
val request1 : ('a -> 'b -> unit Thread.Deferred.t) -> ('c * (once:bool -> ('d -> unit) -> 'e -> unit)) -> 'f -> 'g -> 'h Thread.Deferred.t
val reply1 : ('a * (once:bool -> ('b -> unit) -> 'c -> unit)) -> ('d -> 'e -> 'f Thread.Deferred.t) -> ?once:bool -> 'g -> ('h -> 'i Thread.Deferred.t) -> 'f Thread.Deferred.t
val request2 : ((Framing.t * Framing.channel_no) -> 'a -> unit Thread.Deferred.t) -> (Amqp_client_lib.Types.message_id * (once:bool -> ('b -> unit) -> (Framing.t * Framing.channel_no) -> unit)) -> ('b -> 'c) -> (Amqp_client_lib.Types.message_id * (once:bool -> ('d -> unit) -> (Framing.t * Framing.channel_no) -> unit)) -> ('d -> 'c) -> (Framing.t * Framing.channel_no) -> 'e -> 'f Thread.Deferred.t