A configurable source of time.
A queue of delayed elements.
Slow down a stream by enforcing a delay between items.
Allows a future or stream to execute for a maximum amount of time.
A future that completes at a specified instant in time.
Errors encountered by the timer implementation.
A measurement of a monotonically nondecreasing clock.
Opaque and useful only with
A stream representing notifications at fixed interval
A measurement of the system clock, useful for talking to external entities like the file system or other processes.
An anchor in time which can be used to create new
Create a Future that completes in