Index of modules

Async's implementation of the standard notion of a "condition" variable.

Async's analog of Core.Gc.

The deferred analog of Core.Or_error.

An immutable sequence of values, with a possibly incomplete tail that may be extended asynchronously.

Schedule jobs to run at a time in the future.

Settings that globally affect the behavior of async.

Internal async debugging functions.

The Deferred module exposed here is for async's internal use only.

A value that will become determined asynchronously.

default how is `Sequential

Events provide abortable versions of at and after.

The context in which an async job runs.

A continuation that captures the current async execution context.

A write-once cell that can be empty or full (i.e.

Internal to async -- an atomic unit of work to be run by the scheduler.

Internal to async -- queues of jobs to run, one at each priority level.

Internal to async -- a timestamp used to implement Monitor.kill.

A delayed computation that can produce a deferred.

The part of the Execution_context that determines what to do when there is an unhandled exception.

A buffered FIFO communication channel.

The priority of a job.

Internal to async -- see Deferred for the public API.

Internal to async -- see Ivar for the public API.

Internal to async -- see Async_unix.Scheduler for the public API.

A sequencer is a throttle that is specialized to only allow one job at a time and to, by default, not continue on error.

We use a phantom type to distinguish between throttles, which have max_concurrent_jobs >= 1, and sequencers, which have max_concurrent_jobs = 1.

A pointer to the end of an Async_stream that can be used to extend the stream.

Nothing here.

A way to limit the number of concurrent computations.

Debugging for Throttle.

This signature is here to remind us to update the unit tests whenever we change Throttle.

Internal to async.