public final Class FlowableReduceWithSingle<T, R>

Class Inheritance

extends Single<R>

java.lang.Object
io.reactivex.Single
io.reactivex.internal.operators.flowable.FlowableReduceWithSingle

Type Parameters

<T>: the source value type
<R>: the accumulated result type

Imports

java.util.concurrent.Callable, org.reactivestreams.Publisher, io.reactivex.*, io.reactivex.exceptions.Exceptions, io.reactivex.functions.BiFunction, io.reactivex.internal.disposables.EmptyDisposable, io.reactivex.internal.functions.ObjectHelper, io.reactivex.internal.operators.flowable.FlowableReduceSeedSingle.ReduceSeedObserver

Reduce a sequence of values, starting from a generated seed value and by using an accumulator function and return the last accumulated value.

Field Summary

Modifier and Type	Field and Description
pack-priv final BiFunction<R, ? super T, R>	reducer
pack-priv final Callable<R>	seedSupplier
pack-priv final Publisher<T>	source

Constructor Summary

Access	Constructor and Description
public	FlowableReduceWithSingle(Publisher<T> source, Callable<R> seedSupplier, BiFunction<R, ? super T, R> reducer)

Method Summary

Modifier and Type	Method and Description
protected void	subscribeActual(SingleObserver<? super R> the SingleObserver to handle, not null observer) Implements abstract io.reactivex.Single.subscribeActual. Implement this method in subclasses to handle the incoming `SingleObserver`s.

Inherited from io.reactivex.Single:: amb ambArray ambWith as blockingGet cache cast compose concat concat concat concat concat concat concat concatArray concatArrayEager concatEager concatEager concatWith contains contains create defer delay delay delay delay delaySubscription delaySubscription delaySubscription delaySubscription delaySubscription delaySubscription dematerialize doAfterSuccess doAfterTerminate doFinally doOnDispose doOnError doOnEvent doOnSubscribe doOnSuccess doOnTerminate equals error error filter flatMap flatMapCompletable flatMapMaybe flatMapObservable flatMapPublisher flattenAsFlowable flattenAsObservable fromCallable fromFuture fromFuture fromFuture fromFuture fromObservable fromPublisher hide ignoreElement just lift map materialize merge merge merge merge merge merge mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeWith never observeOn onErrorResumeNext onErrorResumeNext onErrorReturn onErrorReturnItem onTerminateDetach repeat repeat repeatUntil repeatWhen retry retry retry retry retry retryWhen subscribe subscribe subscribe subscribe subscribe subscribeOn subscribeWith takeUntil takeUntil takeUntil test test timeout timeout timeout timeout timer timer to toCompletable toFlowable toFuture toMaybe toObservable unsafeCreate unsubscribeOn using using wrap zip zip zip zip zip zip zip zip zip zipArray zipWith

Field Detail

reducer	back to summary
pack-priv final BiFunction<R, ? super T, R> reducer

seedSupplier	back to summary
pack-priv final Callable<R> seedSupplier

source	back to summary
pack-priv final Publisher<T> source

Constructor Detail

FlowableReduceWithSingle	back to summary
public FlowableReduceWithSingle(Publisher<T> source, Callable<R> seedSupplier, BiFunction<R, ? super T, R> reducer)

Method Detail

subscribeActual back to summary

subscribeActual	back to summary
protected void subscribeActual(SingleObserver<? super R> observer) Implements abstract io.reactivex.Single.subscribeActual. Doc from io.reactivex.Single.subscribeActual. Implement this method in subclasses to handle the incoming `SingleObserver`s. There is no need to call any of the plugin hooks on the current `Single` instance or the `SingleObserver`; all hooks and basic safeguards have been applied by `subscribe(SingleObserver)` before this method gets called. Parameters observer:SingleObserver<? super R> the SingleObserver to handle, not null Annotations @Override

protected void subscribeActual(SingleObserver<? super R> observer)

Implements abstract io.reactivex.Single.subscribeActual.

Doc from io.reactivex.Single.subscribeActual.

Implement this method in subclasses to handle the incoming SingleObservers.

There is no need to call any of the plugin hooks on the current Single instance or the SingleObserver; all hooks and basic safeguards have been applied by subscribe(SingleObserver) before this method gets called.

Parameters

observer:SingleObserver<? super R>: the SingleObserver to handle, not null

Annotations

@Override