mirror of
https://github.com/c-cube/moonpool.git
synced 2026-01-27 19:54:50 -05:00
fut: fix warnings
This commit is contained in:
parent
ab718b22f9
commit
e4b159c695
1 changed files with 4 additions and 4 deletions
|
|
@ -97,7 +97,7 @@ let spawn ~on f : _ t =
|
||||||
fulfill promise res
|
fulfill promise res
|
||||||
in
|
in
|
||||||
|
|
||||||
Pool.run on task;
|
Pool.run_async on task;
|
||||||
fut
|
fut
|
||||||
|
|
||||||
let map ?on ~f fut : _ t =
|
let map ?on ~f fut : _ t =
|
||||||
|
|
@ -123,7 +123,7 @@ let map ?on ~f fut : _ t =
|
||||||
|
|
||||||
match on with
|
match on with
|
||||||
| None -> map_and_fulfill ()
|
| None -> map_and_fulfill ()
|
||||||
| Some on -> Pool.run on map_and_fulfill);
|
| Some on -> Pool.run_async on map_and_fulfill);
|
||||||
|
|
||||||
fut2
|
fut2
|
||||||
|
|
||||||
|
|
@ -150,14 +150,14 @@ let bind ?on ~f fut : _ t =
|
||||||
| None -> apply_f_to_res r
|
| None -> apply_f_to_res r
|
||||||
| Some on ->
|
| Some on ->
|
||||||
let fut2, promise = make () in
|
let fut2, promise = make () in
|
||||||
Pool.run on (bind_and_fulfill r promise);
|
Pool.run_async on (bind_and_fulfill r promise);
|
||||||
fut2)
|
fut2)
|
||||||
| None ->
|
| None ->
|
||||||
let fut2, promise = make () in
|
let fut2, promise = make () in
|
||||||
on_result fut (fun r ->
|
on_result fut (fun r ->
|
||||||
match on with
|
match on with
|
||||||
| None -> bind_and_fulfill r promise ()
|
| None -> bind_and_fulfill r promise ()
|
||||||
| Some on -> Pool.run on (bind_and_fulfill r promise));
|
| Some on -> Pool.run_async on (bind_and_fulfill r promise));
|
||||||
|
|
||||||
fut2
|
fut2
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue