package amqp-client-async

  1. Overview
  2. Docs
package amqp-client-async
Legend:
Library
Module
Module type
Parameter
Class
Class type

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 -> 'a
val read_property_flag : int -> int -> int
val list_create : (unit -> 'a) -> int -> 'a list
val read_method : (Amqp_client_lib.Types.message_id * ('b, 'a) Protocol.Spec.spec * 'b * 'c) -> Amqp_client_lib.Types.message_id * (once:bool -> ('a -> unit) -> (Framing.t * Framing.channel_no) -> unit)
val write_method_content : (Amqp_client_lib.Types.message_id * ('a, Amqp_client_lib.Io.Output.t) Protocol.Spec.spec * 'b * ('a -> 'c -> Amqp_client_lib.Io.Output.t)) -> ((Amqp_client_lib.Types.class_id * 'd) * ('e, Amqp_client_lib.Io.Output.t) Protocol.Content.spec * 'f * ('e -> 'g -> Amqp_client_lib.Io.Output.t)) -> (Framing.t * Framing.channel_no) -> ('c * 'g * string) -> unit Thread.Deferred.t
val read_method_content : (Amqp_client_lib.Types.message_id * ('a, 'b) Protocol.Spec.spec * 'a * 'c) -> ((Amqp_client_lib.Types.class_id * 'd) * ('e, 'f) Protocol.Content.spec * 'e * 'g) -> Amqp_client_lib.Types.message_id * (once:bool -> (('b * ('f * string)) -> unit) -> (Framing.t * Framing.channel_no) -> unit)
val request0 : ('a -> 'b -> 'c) -> 'a -> 'b -> 'c
val reply0 : ('a * (once:bool -> ('b -> unit) -> 'c -> 'd)) -> ?once:bool -> 'c -> 'b Async_kernel.Deferred.t
val request1 : ('a -> 'b -> unit Thread.Deferred.t) -> ('c * (once:bool -> ('d -> unit) -> 'a -> 'e)) -> 'a -> 'b -> 'd Thread.Deferred.t
val reply1 : ('a * (once:bool -> ('b -> unit) -> 'c -> 'd)) -> ('c -> 'e -> 'f Thread.Deferred.t) -> ?once:bool -> 'c -> ('b -> 'e 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) -> '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) -> 'a -> 'd Thread.Deferred.t