public class AsyncIterablePublisher<T> extends java.lang.Object implements Publisher<T>
Constructor and Description |
---|
AsyncIterablePublisher(java.lang.Iterable<T> elements,
java.util.concurrent.Executor executor) |
AsyncIterablePublisher(java.lang.Iterable<T> elements,
int batchSize,
java.util.concurrent.Executor executor) |
Modifier and Type | Method and Description |
---|---|
void |
subscribe(Subscriber<? super T> s)
Request
Publisher to start streaming data. |
public AsyncIterablePublisher(java.lang.Iterable<T> elements, java.util.concurrent.Executor executor)
public AsyncIterablePublisher(java.lang.Iterable<T> elements, int batchSize, java.util.concurrent.Executor executor)
public void subscribe(Subscriber<? super T> s)
Publisher
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)
.
subscribe
in interface Publisher<T>
s
- the Subscriber
that will consume signals from this Publisher