- Type Parameters:
T- the type of item emitted downstream
public interface Upstream<T>An upstream asynchronous data source.
An upstream can be
connectedat any time to a
Downstream, zero or more times. Once connected, the upstream will at some time in the future invoke one of the downstream's
Downstream.complete()methods. Only one of these methods will be invoked per downstream that is connected, and only invoked once.
Multiple downstreams can connect to a single upstream.
- See Also: