Skip to content

Commit d957f7b

Browse files
committed
small refactor
1 parent a26503d commit d957f7b

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

src/core/fut.ml

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -431,8 +431,7 @@ let await (self : 'a t) : 'a =
431431
| exception C.Running ->
432432
let trigger = Trigger.create () in
433433
(* suspend until the future is resolved *)
434-
if C.try_attach self trigger then
435-
Option.iter Exn_bt.raise @@ Trigger.await trigger;
434+
if C.try_attach self trigger then Trigger.await_exn trigger;
436435

437436
(* un-suspended: we should have a result! *)
438437
get_or_fail_exn self

src/forkjoin/moonpool_forkjoin.ml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ module State_ = struct
6464
done;
6565

6666
(* wait for the other computation to be done *)
67-
if !must_await then Trigger.await trigger |> Option.iter Exn_bt.raise
67+
if !must_await then Trigger.await_exn trigger
6868
| Right_solved _ | Both_solved _ -> assert false
6969
end
7070

@@ -144,7 +144,7 @@ let for_ ?chunk_size n (f : int -> int -> unit) : unit =
144144
i := !i + len_range
145145
done;
146146

147-
Trigger.await trigger |> Option.iter Exn_bt.raise;
147+
Trigger.await_exn trigger;
148148
Option.iter Exn_bt.raise @@ A.get failure;
149149
()
150150
)

0 commit comments

Comments
 (0)