Protocol_helpers (amqp-client-async.Amqp_client_async.Protocol

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 write_method : 
  (Amqp_client_lib.Types.message_id
   * ('a, Amqp_client_lib.Io.Output.t) Protocol.Spec.spec
   * 'b
   * ('c ->
   'd ->
   Amqp_client_lib.Io.Output.t)) ->
  (Framing.t * Framing.channel_no) ->
  'e ->
  unit Thread.Deferred.t

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 write_method_content : 
  (Amqp_client_lib.Types.message_id
   * ('a, Amqp_client_lib.Io.Output.t) Protocol.Spec.spec
   * 'b
   * ('c ->
   'd ->
   Amqp_client_lib.Io.Output.t)) ->
  ((Amqp_client_lib.Types.class_id * 'e)
   * ('f, Amqp_client_lib.Io.Output.t) Protocol.Content.spec
   * 'g
   * ('h ->
   'i ->
   Amqp_client_lib.Io.Output.t)) ->
  (Framing.t * Framing.channel_no) ->
  ('j * 'k * string) ->
  unit Thread.Deferred.t

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 Async_kernel.Deferred.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