simon/moonpool
1
0
Fork 0
mirror of https://github.com/c-cube/moonpool.git synced 2025-12-06 19:25:35 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

add Chan.pop_await

Browse source
This commit is contained in:
Simon Cruanes 2023-07-09 17:45:25 -04:00
parent 12df71c3ab
commit 68e744290b
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
2 changed files with 18 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/chan.ml
View file

@ -182,3 +182,12 @@ let close (self : _ t) : unit =
do do
Domain_.relax () Domain_.relax ()
done done
[@@@ifge 5.0]
let pop_await self =
match try_pop self with
| Some x -> x
| None -> Fut.await @@ pop self
[@@@endif]

9
src/chan.mli
View file

@ -41,3 +41,12 @@ val pop_block_exn : 'a t -> 'a
val close : _ t -> unit val close : _ t -> unit
(** Close the channel. Further push and pop calls will fail. (** Close the channel. Further push and pop calls will fail.
This is idempotent. *) This is idempotent. *)
[@@@ifge 5.0]
val pop_await : 'a t -> 'a
(** Like {!pop} but suspends the current thread until an element is
available. See {!Fut.await} for more details.
@since NEXT_RELEASE *)
[@@@endif]