Module Clock

module Clock: Clock

module Event: sig .. end

Events provide a way to "abort" at and after requests.

val after : Core.Std.Time.Span.t -> unit Deferred.t

after span returns a deferred d that will become determined after the span of time passes. If the span is nonpositive, then the deferred will be immediately determined.

If you set up a lot of after events at the beginning of your program they will trigger at the same time. Use Time.Span.randomize to even that out.

For after_event, if the event is aborted and d is not yet determined, then d will never become determined, and no more space will be required for tracking the event, i.e. the corresponding element will be removed from the heap.

val after_event : Core.Std.Time.Span.t -> [ `Aborted | `Happened ] Deferred.t * Event.t

val with_timeout : Core.Std.Time.Span.t ->
       'a Deferred.t -> [ `Result of 'a | `Timeout ] Deferred.t

with_timeout span d does pretty much what one can expect. Note that at the point of checking, if d is determined and the timeout has expired, the resulting deferred will be determined with `Result. In other words, since there is inherent race between d and the timeout, the preference is given to d.

val at : Core.Std.Time.t -> unit Deferred.t

at time returns a deferred d that will become determined as soon as possible after the specified time. Of course, it can't become determined before at is called, so calling at on a time not in the future will return a deferred that is immediately determined.

For at_event, if the event is aborted and the result of at is not yet determined, then the result will never become determined, and no more space will be required by async for tracking the at, i.e. the corresponding element will be removed from the heap.

val at_event : Core.Std.Time.t -> [ `Aborted | `Happened ] Deferred.t * Event.t

val at_varying_intervals : ?stop:unit Deferred.t ->
       (unit -> Core.Std.Time.Span.t) -> unit Async_stream.t

at_varying_intervals ~stop f returns a stream whose next element becomes determined by calling f () and waiting for that amount of time, and then looping to determine subsequent elements. The stream will end after stop becomes determined.

val at_intervals : ?stop:unit Deferred.t -> Core.Std.Time.Span.t -> unit Async_stream.t

at_intervals ~stop span returns a stream whose elements will become determined span time apart. The stream will end after stop becomes determined.

at_intervals ~stop span = at_varying_intervals ~stop (fun () -> span)

val every' : ?start:unit Deferred.t ->
       ?stop:unit Deferred.t ->
       ?continue_on_error:bool ->
       Core.Std.Time.Span.t -> (unit -> unit Deferred.t) -> unit

every' ?start ?stop span f runs f() every span amount of time starting when start becomes determined and stopping when stop becomes determined. every waits until the result of f() becomes determined before waiting for the next span.

Note that it has span delay even before the first call of f.

It is guaranteed that if stop becomes determined, even during evaluation of f, then f will not be called again by a subsequent iteration of the loop.

It is an error for span to be nonpositive.

val every : ?start:unit Deferred.t ->
       ?stop:unit Deferred.t ->
       ?continue_on_error:bool -> Core.Std.Time.Span.t -> (unit -> unit) -> unit

every ?start ?stop span f is every' ?start ?stop span (fun () -> f (); Deferred.unit)