public static class Utils.MappingObservableSubscriber<T,R> extends Object implements org.reactivestreams.Subscriber<T>
| Constructor and Description |
|---|
MappingObservableSubscriber(Vertx vertx,
java.util.function.Function<T,R> converter,
Handler<AsyncResult<List<R>>> resultHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
onComplete() |
void |
onError(Throwable t) |
void |
onNext(T t) |
void |
onSubscribe(org.reactivestreams.Subscription s) |
public MappingObservableSubscriber(Vertx vertx, java.util.function.Function<T,R> converter, Handler<AsyncResult<List<R>>> resultHandler)
public void onSubscribe(org.reactivestreams.Subscription s)
onSubscribe in interface org.reactivestreams.Subscriber<T>public void onError(Throwable t)
onError in interface org.reactivestreams.Subscriber<T>public void onComplete()
onComplete in interface org.reactivestreams.Subscriber<T>Copyright © 2019 Eclipse. All rights reserved.