Fix race in monitor test

issuu · Oct 21, 2023 · fc0f0df · fc0f0df
1 parent 7651911
commit fc0f0df
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/zmq/test/zmq_test.ml b/zmq/test/zmq_test.ml
@@ -138,8 +138,9 @@ let test_monitor () =
  end;
  Zmq.Socket.close s1;
  assert_event "m1" m1 "Closed";
- Zmq.Socket.close s2;
+ assert_event "m1" m1 "Monitor_stopped";
  assert_event "m2" m2 "Disconnect";
+ Zmq.Socket.close s2;
 
  Zmq.Socket.close m2;
  Zmq.Socket.close m1;
@@ -165,7 +166,7 @@ let test_proxy () =
  in
 
  let _thread = Thread.create proxy (pull, pub) in
- sleep 10;
+ sleep 10; (* Wait until the proxy has been created *)
  let sub =
  let s = Zmq.Socket.create ctx sub in
  Zmq.Socket.connect s pub_endpoint;