public final class PublisherRedo<T>
extends java.lang.Object
implements org.reactivestreams.Publisher<T>
| Constructor and Description |
|---|
PublisherRedo(org.reactivestreams.Publisher<? extends T> source,
Function<? super Observable<Try<Optional<java.lang.Object>>>,? extends org.reactivestreams.Publisher<?>> manager) |
| Modifier and Type | Method and Description |
|---|---|
void |
subscribe(org.reactivestreams.Subscriber<? super T> s) |
public PublisherRedo(org.reactivestreams.Publisher<? extends T> source, Function<? super Observable<Try<Optional<java.lang.Object>>>,? extends org.reactivestreams.Publisher<?>> manager)