public final class QueryMap<T,R> extends Query<R>
QueryMap(Query<T> query, Function<? super T,? extends R> mapper)
CompletableFuture<Void>
subscribe(Consumer<? super R> onNext, Consumer<? super Throwable> onError)
blockingSubscribe, distinct, filter, flatMapConcat, flatMapMerge, fork, map, of, of, of, onError, onNext, skip, takeWhile
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public QueryMap(Query<T> query, Function<? super T,? extends R> mapper)
public CompletableFuture<Void> subscribe(Consumer<? super R> onNext, Consumer<? super Throwable> onError)
subscribe
Query<R>