Fix to use await as there is a race

ocaml-multicore · Sep 10, 2024 · d2aa36c · d2aa36c
1 parent fa1da88
commit d2aa36c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/picos_io/picos_io.ml b/lib/picos_io/picos_io.ml
@@ -411,9 +411,9 @@ module Unix = struct
               else zip_filter pred xs ys
           | _, _ -> []
         in
-        ( zip_filter Computation.peek_exn rds rdcs,
-          zip_filter Computation.peek_exn wrs wrcs,
-          zip_filter Computation.peek_exn exs excs )
+        ( zip_filter Computation.await rds rdcs,
+          zip_filter Computation.await wrs wrcs,
+          zip_filter Computation.await exs excs )
     | exception cancelation_exn ->
         Computation.cancel overall Done empty_bt;
         raise cancelation_exn