Top Inners Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.single

public final Class SingleZipIterable<T, R>

extends Single<R>
Class Inheritance
Imports
java.util.*, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.Function, io.reactivex.rxjava3.internal.disposables.EmptyDisposable, io.reactivex.rxjava3.internal.operators.single.SingleZipArray.ZipCoordinator

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class
SingleZipIterable.SingletonArrayFunc

Field Summary

Modifier and TypeField and Description
pack-priv final Iterable<? extends SingleSource<? extends T>>
sources

pack-priv final Function<? super Object[], ? extends R>
zipper

Constructor Summary

AccessConstructor and Description
public
SingleZipIterable(Iterable<? extends SingleSource<? extends T>> sources, Function<? super Object[], ? extends R> zipper)

Method Summary

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

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

Field Detail

sourcesback to summary
pack-priv final Iterable<? extends SingleSource<? extends T>> sources
zipperback to summary
pack-priv final Function<? super Object[], ? extends R> zipper

Constructor Detail

SingleZipIterableback to summary
public SingleZipIterable(Iterable<? extends SingleSource<? extends T>> sources, Function<? super Object[], ? extends R> zipper)

Method Detail

subscribeActualback to summary
protected void subscribeActual(SingleObserver<? super R> observer)
Annotations
@Override
io.reactivex.rxjava3.internal.operators.single back to summary

pack-priv final Class SingleZipIterable.SingletonArrayFunc

extends Object
implements Function<T, R>
Class Inheritance
  • java.lang.Object
  • io.reactivex.rxjava3.internal.operators.single.SingleZipIterable.SingletonArrayFunc
All Implemented Interfaces
io.reactivex.rxjava3.functions.Function

Constructor Summary

AccessConstructor and Description
pack-priv
SingletonArrayFunc()

Method Summary

Modifier and TypeMethod and Description
public R
apply(T
the input value
t)

Implements io.reactivex.rxjava3.functions.Function.apply.

Apply some calculation to the input value and return some other value.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

SingletonArrayFuncback to summary
pack-priv SingletonArrayFunc()

Method Detail

applyback to summary
public R apply(T t) throws Throwable

Implements io.reactivex.rxjava3.functions.Function.apply.

Doc from io.reactivex.rxjava3.functions.Function.apply.

Apply some calculation to the input value and return some other value.

Parameters
t:T

the input value

Returns:R

the output value

Annotations
@Override
Exceptions
Throwable:
if the implementation wishes to throw any type of exception