Merge pull request #46 from beano/feature-consumer-opts

Expose arguments on consume API
andersfugmann · Jan 29, 2024 · 6813dda · 6813dda
2 parents bd7ecbf + 1208231
commit 6813dda
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/async/src/queue.ml b/async/src/queue.ml
@@ -50,7 +50,7 @@ type 'a consumer = { channel: 'a Channel.t;
                      writer: Message.t Pipe.Writer.t }
 
 (** Consume message from a queue. *)
-let consume ~id ?(no_local=false) ?(no_ack=false) ?(exclusive=false)
+let consume ~id ?(no_local=false) ?(no_ack=false) ?(exclusive=false) ?(arguments=[])
     ?on_cancel channel t =
   let open Spec.Basic in
   let (reader, writer) = Pipe.create () in
@@ -77,7 +77,7 @@ let consume ~id ?(no_local=false) ?(no_ack=false) ?(exclusive=false)
               no_ack;
               exclusive;
               no_wait = false;
-              arguments = [];
+              arguments;
             }
   in
   let var = Ivar.create () in

diff --git a/async/src/queue.mli b/async/src/queue.mli
@@ -63,6 +63,7 @@ val consume :
   ?no_local:bool ->
   ?no_ack:bool ->
   ?exclusive:bool ->
+  ?arguments:Types.table ->
   ?on_cancel:(unit -> unit) ->
   'a Channel.t ->
   t ->