amqp-client-lwt

Amqp client library, lwt version
IN THIS PACKAGE

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 -> 'd )) -> ?once:bool -> 'e -> 'f Lwt.t
val request1 : ( 'a -> 'b -> unit Thread.Deferred.t ) -> ('c * ( once:bool -> ( 'd -> unit ) -> 'e -> 'f )) -> 'g -> 'h -> 'i Thread.Deferred.t
val reply1 : ('a * ( once:bool -> ( 'b -> unit ) -> 'c -> 'd )) -> ( 'e -> 'f -> 'g Thread.Deferred.t ) -> ?once:bool -> 'h -> ( 'i -> 'j Thread.Deferred.t ) -> 'g 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) -> 'c )) -> ( 'b -> 'd ) -> (Amqp_client_lib.Types.message_id * ( once:bool -> ( 'e -> unit ) -> (Framing.t * Framing.channel_no) -> 'f )) -> ( 'e -> 'd ) -> (Framing.t * Framing.channel_no) -> 'g -> 'h Thread.Deferred.t