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.observers | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.maybe | |
io.reactivex.internal.operators.observable | |
io.reactivex.internal.operators.parallel | |
io.reactivex.internal.operators.single | |
io.reactivex.parallel |
Contains the base type
ParallelFlowable ,
a sub-DSL for working with Flowable sequences in parallel. |
Modifier and Type | Method and Description |
---|---|
<U> Single<U> |
Flowable.collect(Callable<? extends U> initialItemSupplier,
BiConsumer<? super U,? super T> collector)
Collects items emitted by the finite source Publisher into a single mutable data structure and returns
a Single that emits this structure.
|
<U> Single<U> |
Observable.collect(Callable<? extends U> initialValueSupplier,
BiConsumer<? super U,? super T> collector)
Collects items emitted by the finite source ObservableSource into a single mutable data structure and returns
a Single that emits this structure.
|
<U> Single<U> |
Flowable.collectInto(U initialItem,
BiConsumer<? super U,? super T> collector)
Collects items emitted by the finite source Publisher into a single mutable data structure and returns
a Single that emits this structure.
|
<U> Single<U> |
Observable.collectInto(U initialValue,
BiConsumer<? super U,? super T> collector)
Collects items emitted by the finite source ObservableSource into a single mutable data structure and returns
a Single that emits this structure.
|
Maybe<T> |
Maybe.doOnEvent(BiConsumer<? super T,? super Throwable> onEvent)
Calls the given onEvent callback with the (success value, null) for an onSuccess, (null, throwable) for
an onError or (null, null) for an onComplete signal from this Maybe before delivering said
signal to the downstream.
|
Single<T> |
Single.doOnEvent(BiConsumer<? super T,? super Throwable> onEvent)
Calls the shared consumer with the error sent via onError or the value
via onSuccess for each SingleObserver that subscribes to the current Single.
|
static <T,S> Flowable<T> |
Flowable.generate(Callable<S> initialState,
BiConsumer<S,Emitter<T>> generator)
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
|
static <T,S> Observable<T> |
Observable.generate(Callable<S> initialState,
BiConsumer<S,Emitter<T>> generator)
Returns a cold, synchronous and stateful generator of values.
|
static <T,S> Flowable<T> |
Flowable.generate(Callable<S> initialState,
BiConsumer<S,Emitter<T>> generator,
Consumer<? super S> disposeState)
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
|
static <T,S> Observable<T> |
Observable.generate(Callable<S> initialState,
BiConsumer<S,Emitter<T>> generator,
Consumer<? super S> disposeState)
Returns a cold, synchronous and stateful generator of values.
|
Disposable |
Single.subscribe(BiConsumer<? super T,? super Throwable> onCallback)
Subscribes to a Single and provides a composite callback to handle the item it emits
or any error notification it issues.
|
Modifier and Type | Method and Description |
---|---|
static <T,K> BiConsumer<Map<K,T>,T> |
Functions.toMapKeySelector(Function<? super T,? extends K> keySelector) |
static <T,K,V> BiConsumer<Map<K,V>,T> |
Functions.toMapKeyValueSelector(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector) |
static <T,K,V> BiConsumer<Map<K,Collection<V>>,T> |
Functions.toMultimapKeyValueSelector(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Function<? super K,? extends Collection<? super V>> collectionFactory) |
Constructor and Description |
---|
BiConsumerSingleObserver(BiConsumer<? super T,? super Throwable> onCallback) |
Modifier and Type | Method and Description |
---|---|
static <T,S> BiFunction<S,Emitter<T>,S> |
FlowableInternalHelper.simpleBiGenerator(BiConsumer<S,Emitter<T>> consumer) |
Constructor and Description |
---|
FlowableCollect(Flowable<T> source,
Callable<? extends U> initialSupplier,
BiConsumer<? super U,? super T> collector) |
FlowableCollectSingle(Flowable<T> source,
Callable<? extends U> initialSupplier,
BiConsumer<? super U,? super T> collector) |
Constructor and Description |
---|
MaybeDoOnEvent(MaybeSource<T> source,
BiConsumer<? super T,? super Throwable> onEvent) |
Modifier and Type | Method and Description |
---|---|
static <T,S> BiFunction<S,Emitter<T>,S> |
ObservableInternalHelper.simpleBiGenerator(BiConsumer<S,Emitter<T>> consumer) |
Constructor and Description |
---|
ObservableCollect(ObservableSource<T> source,
Callable<? extends U> initialSupplier,
BiConsumer<? super U,? super T> collector) |
ObservableCollectSingle(ObservableSource<T> source,
Callable<? extends U> initialSupplier,
BiConsumer<? super U,? super T> collector) |
Constructor and Description |
---|
ParallelCollect(ParallelFlowable<? extends T> source,
Callable<? extends C> initialCollection,
BiConsumer<? super C,? super T> collector) |
Constructor and Description |
---|
SingleDoOnEvent(SingleSource<T> source,
BiConsumer<? super T,? super Throwable> onEvent) |
Modifier and Type | Method and Description |
---|---|
<C> ParallelFlowable<C> |
ParallelFlowable.collect(Callable<? extends C> collectionSupplier,
BiConsumer<? super C,? super T> collector)
Collect the elements in each rail into a collection supplied via a collectionSupplier
and collected into with a collector action, emitting the collection at the end.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.