Top Description Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.observable

public final Class ObservableReduceWithSingle<T, R>

extends Single<R>
Class Inheritance
Type Parameters
<T>
the source value type
<R>
the accumulated result type
Imports
io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.*, io.reactivex.rxjava3.internal.disposables.EmptyDisposable, io.reactivex.rxjava3.internal.operators.observable.ObservableReduceSeedSingle.ReduceSeedObserver, java.util.Objects
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 TypeField and Description
pack-priv final BiFunction<R, ? super T, R>
reducer

pack-priv final Supplier<R>
seedSupplier

pack-priv final ObservableSource<T>
source

Constructor Summary

AccessConstructor and Description
public
ObservableReduceWithSingle(ObservableSource<T> source, Supplier<R> seedSupplier, BiFunction<R, ? super T, R> reducer)

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(SingleObserver<? super R> observer)

Inherited from io.reactivex.rxjava3.core.Single:
ambambArrayambWithblockingGetblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribecachecastcomposeconcatconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatArrayEagerconcatArrayEagerDelayErrorconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatEagerconcatEagerconcatEagerconcatEagerconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatMapconcatMapCompletableconcatMapMaybeconcatWithcontainscontainscreatedeferdelaydelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondematerializedoAfterSuccessdoAfterTerminatedoFinallydoOnDisposedoOnErrordoOnEventdoOnLifecycledoOnSubscribedoOnSuccessdoOnTerminateerrorerrorfilterflatMapflatMapflatMapflatMapCompletableflatMapMaybeflatMapObservableflatMapPublisherflattenAsFlowableflattenAsObservableflattenStreamAsFlowableflattenStreamAsObservablefromCallablefromCompletionStagefromFuturefromFuturefromMaybefromMaybefromObservablefromPublisherfromSupplierhideignoreElementjustliftmapmapOptionalmaterializemergemergemergemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnofTypeonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeWithonErrorReturnonErrorReturnItemonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryUntilretryWhensafeSubscribesequenceEqualstartWithstartWithstartWithstartWithstartWithsubscribesubscribesubscribesubscribesubscribesubscribesubscribeActualsubscribeOnsubscribeWithswitchOnNextswitchOnNextDelayErrortakeUntiltakeUntiltakeUntiltesttesttimeIntervaltimeIntervaltimeIntervaltimeIntervaltimeouttimeouttimeouttimeouttimertimertimestamptimestamptimestamptimestamptotoCompletionStagetoFlowabletoFuturetoMaybetoObservableunsafeCreateunsubscribeOnusingusingwrapzipzipzipzipzipzipzipzipzipzipArrayzipWith

Field Detail

reducerback to summary
pack-priv final BiFunction<R, ? super T, R> reducer
seedSupplierback to summary
pack-priv final Supplier<R> seedSupplier
sourceback to summary
pack-priv final ObservableSource<T> source

Constructor Detail

ObservableReduceWithSingleback to summary
public ObservableReduceWithSingle(ObservableSource<T> source, Supplier<R> seedSupplier, BiFunction<R, ? super T, R> reducer)

Method Detail

subscribeActualback to summary
protected void subscribeActual(SingleObserver<? super R> observer)
Annotations
@Override