devkit

Development kit - general purpose library
IN THIS PACKAGE
val with_count : int ref -> 'a Lwt.t -> 'a Lwt.t
val timely : Time.t -> ( 'a -> unit Lwt.t ) -> 'a -> unit Lwt.t
val timely_loop' : ?immediate:bool -> Time.t -> ( unit -> unit Lwt.t ) -> unit Lwt.t

timely_loop' ?immediate period f run f every period seconds; run immediately if immediate is true.

val timely_loop : ?immediate:bool -> ?wait:unit Lwt.t -> Time.t -> ( unit -> unit Lwt.t ) -> unit Lwt.t

timely_loop' ?immediate ?wait period f run f every period seconds; run immediately if immediate is true; stop when wait thread terminates.

val ensure_order : 'a Lwt.t -> 'b Lwt.t -> 'b Lwt.t

ensure_order t1 t2 cancel t1 when t2 terminates.

val suppress_exn : string -> ( unit -> 'a Lwt.t ) -> unit Lwt.t -> 'a Lwt.t

suppress_exn name cleanup t wait for t to terminate, suppress any exception, and call cleanup () afterwards.

val action : string -> ( 'a -> 'b Lwt.t ) -> 'a -> 'b Lwt.t
val action_do : string -> ( unit -> 'a Lwt.t ) -> 'a Lwt.t
val async : ( unit -> unit Lwt.t ) -> unit

same as Lwt.async but also cancels task on Daemon.ShouldExit