org.reactivestreams.Publisher<T>
InfiniteIncrementNumberPublisher
, NumberIterablePublisher
public class AsyncIterablePublisher<T> extends java.lang.Object implements org.reactivestreams.Publisher<T>
Constructor | Description |
---|---|
AsyncIterablePublisher(java.lang.Iterable<T> elements,
int batchSize,
java.util.concurrent.Executor executor) |
|
AsyncIterablePublisher(java.lang.Iterable<T> elements,
java.util.concurrent.Executor executor) |
Modifier and Type | Method | Description |
---|---|---|
void |
subscribe(org.reactivestreams.Subscriber<? super T> s) |
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)