Represents the acknowledgement of processing that a consumer
sends back upstream on
A channel is meant for imperative style feeding of events.
Used by Observable.materialize.
The Observable interface in the Rx pattern.
Channel, which are meant for imperatively building Observables without back-pressure concerns
Subject, which are both Observables and Observers
Cancelable, the type returned by higher
subscribe variants and that can be used to cancel subscriptions
Scheduler, our enhanced
Observer, the interface that must be implemented by consumers
The Observer from the Rx pattern is the trio of callbacks that get subscribed to an Observable for receiving events.
Represents the buffering overflowStrategy chosen for actions that need buffering, instructing the pipeline what to do when the buffer is full.
Subscriber value is a named tuple of an observer and a scheduler,
whose usage is in Observable.create.