public interface Publisher<T,S extends Subscriber<T>>
Modifier and Type | Method and Description |
---|---|
void |
subscribe(S s)
Request
Publisher to start streaming data. |
void subscribe(S s)
Publisher
to start streaming data.
This is a "factory method" and can be called multiple times, each time starting a new Subscription
.
Each Subscription
will work for only a single Subscriber
.
A Subscriber
should only subscribe once to a single Publisher
.
If the Publisher
rejects the subscription attempt or otherwise fails it will
signal the error via Subscriber.onError(java.lang.Throwable)
.
s
- the Subscriber
that will consume signals from this Publisher
Copyright © 2015. All rights reserved.