Fix Lwt_react tests

ocsigen · Dec 15, 2019 · 835ed46 · 835ed46
1 parent 6a02f42
commit 835ed46
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/test/react/test_lwt_event.ml b/test/react/test_lwt_event.ml
@@ -61,8 +61,11 @@ let suite = suite "lwt_event" [
        push 0;
        push 1;
 
-       Lwt_main.run (Lwt_unix.sleep 2.5);
-       return (!l = [2;2;0]));
+       Lwt_unix.sleep 2.5 >>= fun () ->
+       let result = !l = [2; 2; 0] in
+       if not result then
+        List.iter (Printf.eprintf "%i ") !l;
+       return result);
 
 
   test "of_stream"
@@ -90,10 +93,13 @@ let suite = suite "lwt_event" [
          push 0;
          push 2; (* overwrites previous 0 *)
          Lwt_condition.signal cond ();
+         Lwt.pause () >>= fun () ->
          push 3;
          Lwt_condition.signal cond ();
+         Lwt.pause () >>= fun () ->
          push 4;
          Lwt_condition.signal cond ();
+         Lwt.pause () >>= fun () ->
          return (!l = [4; 3; 2; 1]));
 
   test "with_finaliser lifetime" begin fun () ->

diff --git a/test/react/test_lwt_signal.ml b/test/react/test_lwt_signal.ml
@@ -16,14 +16,18 @@ let suite = suite "lwt_signal" [
        let e       = React.E.map (fun x -> l := x :: !l) (React.S.changes s') in
          ignore e;
          Lwt_condition.signal cond ();
+         Lwt.pause () >>= fun () ->
          push 1;
          push 0;
          push 2; (* overwrites previous 0 *)
          Lwt_condition.signal cond ();
+         Lwt.pause () >>= fun () ->
          push 3;
          Lwt_condition.signal cond ();
+         Lwt.pause () >>= fun () ->
          push 4;
          Lwt_condition.signal cond ();
+         Lwt.pause () >>= fun () ->
          return (!l = [4; 3; 2; 1]));
 
   test "limit race condition" begin fun () ->