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

add Moonpool_lwt.spawn_lwt_ignore

Browse source
This commit is contained in:
Simon Cruanes 2025-09-08 10:49:11 -04:00
parent 2aabc30b70
commit f245f4913c
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
2 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/lwt/moonpool_lwt.ml
View file

@ -306,6 +306,8 @@ let spawn_lwt f : _ Lwt.t =
with exn -> Lwt.wakeup_exn lwt_prom exn); with exn -> Lwt.wakeup_exn lwt_prom exn);
lwt_fut lwt_fut
let spawn_lwt_ignore f = ignore (spawn_lwt f : unit Lwt.t)
let lwt_main (f : _ -> 'a) : 'a = let lwt_main (f : _ -> 'a) : 'a =
let st = setup () in let st = setup () in
(* make sure to cleanup *) (* make sure to cleanup *)

3
src/lwt/moonpool_lwt.mli
View file

@ -27,6 +27,9 @@ val spawn_lwt : (unit -> 'a) -> 'a Lwt.t
(** This spawns a task that runs in the Lwt scheduler. (** This spawns a task that runs in the Lwt scheduler.
@raise Failure if {!lwt_main} was not called. *) @raise Failure if {!lwt_main} was not called. *)
val spawn_lwt_ignore : (unit -> unit) -> unit
(** Like {!spawn_lwt} but ignores the result, like [Lwt.async]. *)
val await_lwt : 'a Lwt.t -> 'a val await_lwt : 'a Lwt.t -> 'a
(** [await_lwt fut] awaits a Lwt future from inside a task running on a moonpool (** [await_lwt fut] awaits a Lwt future from inside a task running on a moonpool
runner. This must be run from within a Moonpool runner so that the await-ing runner. This must be run from within a Moonpool runner so that the await-ing