public final class PublisherGenerate<T,S>
extends java.lang.Object
implements org.reactivestreams.Publisher<T>
| Constructor and Description |
|---|
PublisherGenerate(Supplier<S> stateSupplier,
BiFunction<S,org.reactivestreams.Subscriber<T>,S> generator,
Consumer<? super S> disposeState) |
| Modifier and Type | Method and Description |
|---|---|
void |
subscribe(org.reactivestreams.Subscriber<? super T> s) |