Fix Lwt_stream.iter_p to use bind (#608)

To avoid stack overflow.
ocsigen · Aug 23, 2018 · 1d4ffb7 · 1d4ffb7
1 parent 56306a5
commit 1d4ffb7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/core/lwt_stream.ml b/src/core/lwt_stream.ml
@@ -888,7 +888,9 @@ let rec iter_p_rec node f s =
     match node.data with
     | Some x ->
       consume s node;
-      Lwt.join [f x; iter_p_rec node.next f s]
+      let res = f x in
+      let rest = iter_p_rec node.next f s in
+      res >>= fun () -> rest
     | None ->
       Lwt.return_unit