Interface describing Observer wrappers
that are thread-safe (can receive concurrent events) and that
return an immediate
Continue when receiving
underlying Subscriber into an implementation that caches
all events until the call to
Wraps a Subscriber into an implementation that abstains from emitting items until the call
A safe observer ensures too things:
SynchronousObserver is an Observer that signals demand
to upstream synchronously (i.e.
SynchronousSubscriber is a Subscriber whose
is synchronous (i.e.