Represents an acknowledgement of processing that a consumer sends back upstream.
Represents a one-time idempotent action that can be used to cancel async computations, or to release resources that active data sources are holding.
Represents an asynchronous computation that can be canceled as long as it isn't complete.
A Scheduler is an
scala.concurrent.ExecutionContext that additionally can
schedule the execution of units of work to run with a delay or periodically.
An exception reporter is a function that logs an uncaught error.
Utilities for Scala's standard
A small toolkit of classes that support compare-and-swap semantics for safe mutation of variables.
Cancelables represent asynchronous units of work or other things scheduled for execution and whose execution can be canceled.