diff --git a/lib/picos_structured/bundle.ml b/lib/picos_structured/bundle.ml index 2c6f2378..ae8b72ac 100644 --- a/lib/picos_structured/bundle.ml +++ b/lib/picos_structured/bundle.ml @@ -1,5 +1,7 @@ open Picos +let[@inline never] completed () = invalid_arg "already completed" + type t = { num_fibers : int Atomic.t; bundle : unit Computation.t; @@ -63,8 +65,6 @@ let join_after fn = await t fiber packed canceler; Exn_bt.raise exn_bt -let[@inline never] completed () = invalid_arg "already completed" - let rec incr t backoff = let before = Atomic.get t.num_fibers in if before = 0 then completed ()