T- the type of element signaled.
public interface Publisher<T>
Publisheris a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from its
Publisher can serve multiple
at various points in time.
|Modifier and Type||Method||Description|
void subscribe(Subscriber<? super T> s)
Publisherto start streaming data.
This is a "factory method" and can be called multiple times, each time starting a new
Subscription will work for only a single
Subscriber should only subscribe once to a single
Publisher rejects the subscription attempt or otherwise fails it will
signal the error via
Subscriberthat will consume signals from this