Fix send_all on eio

issuu · May 5, 2024 · 8323348 · 8323348
1 parent 7cca40d
commit 8323348
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/zmq-eio/src/socket.ml b/zmq-eio/src/socket.ml
@@ -123,10 +123,10 @@ let send_msg t message =
   request t t.senders (fun () -> Zmq.Socket.send_msg ~block:false t.socket message)
 
 let send_all t =
-  request t t.receivers (fun () -> Zmq.Socket.send_all ~block:false t.socket)
+  request t t.senders (fun () -> Zmq.Socket.send_all ~block:false t.socket)
 
 let send_msg_all t =
-  request t t.receivers (fun () -> Zmq.Socket.send_msg_all ~block:false t.socket)
+  request t t.senders (fun () -> Zmq.Socket.send_msg_all ~block:false t.socket)
 
 let recv t =
   request t t.receivers (fun () -> Zmq.Socket.recv ~block:false t.socket)