Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.functions | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.parallel | |
io.reactivex.parallel |
Contains the base type
ParallelFlowable ,
a sub-DSL for working with Flowable sequences in parallel. |
Modifier and Type | Method and Description |
---|---|
Flowable<T> |
Flowable.doOnLifecycle(Consumer<? super org.reactivestreams.Subscription> onSubscribe,
LongConsumer onRequest,
Action onCancel)
Calls the appropriate onXXX method (shared between all Subscribers) for the lifecycle events of
the sequence (subscription, cancellation, requesting).
|
Flowable<T> |
Flowable.doOnRequest(LongConsumer onRequest)
Modifies the source
Publisher so that it invokes the given action when it receives a
request for more items. |
Modifier and Type | Field and Description |
---|---|
static LongConsumer |
Functions.EMPTY_LONG_CONSUMER |
Constructor and Description |
---|
FlowableDoOnLifecycle(Flowable<T> source,
Consumer<? super org.reactivestreams.Subscription> onSubscribe,
LongConsumer onRequest,
Action onCancel) |
Constructor and Description |
---|
ParallelPeek(ParallelFlowable<T> source,
Consumer<? super T> onNext,
Consumer<? super T> onAfterNext,
Consumer<? super Throwable> onError,
Action onComplete,
Action onAfterTerminated,
Consumer<? super org.reactivestreams.Subscription> onSubscribe,
LongConsumer onRequest,
Action onCancel) |
Modifier and Type | Method and Description |
---|---|
ParallelFlowable<T> |
ParallelFlowable.doOnRequest(LongConsumer onRequest)
Call the specified consumer with the request amount if any rail receives a request.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.