Class DeferredScalarObserver<T,R>

Type Parameters:
T - the input value type
R - the output value type
All Implemented Interfaces:
Observer<T>, Disposable, QueueDisposable<R>, QueueFuseable<R>, SimpleQueue<R>, Serializable

public abstract class DeferredScalarObserver<T,R> extends DeferredScalarDisposable<R> implements Observer<T>
A fuseable Observer that can generate 0 or 1 resulting value.
See Also: