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

public final Class MaybeZipIterable<T, R>

extends Maybe<R>
Class Inheritance
Imports
java.util.Arrays, .Objects, 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.maybe.MaybeZipArray.ZipCoordinator

Nested and Inner Type Summary

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

Field Summary

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

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

Constructor Summary

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

Method Summary

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

Inherited from io.reactivex.rxjava3.core.Maybe:
ambambArrayambWithblockingGetblockingGetblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribecachecastcomposeconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatArrayEagerconcatArrayEagerDelayErrorconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatEagerconcatEagerconcatEagerconcatEagerconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatMapconcatMapCompletableconcatMapSingleconcatWithcontainscountcreatedefaultIfEmptydeferdelaydelaydelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondematerializedoAfterSuccessdoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnErrordoOnEventdoOnLifecycledoOnSubscribedoOnSuccessdoOnTerminateemptyerrorerrorfilterflatMapflatMapflatMapflatMapCompletableflatMapObservableflatMapPublisherflatMapSingleflattenAsFlowableflattenAsObservableflattenStreamAsFlowableflattenStreamAsObservablefromActionfromCallablefromCompletablefromCompletionStagefromFuturefromFuturefromObservablefromOptionalfromPublisherfromRunnablefromSinglefromSupplierhideignoreElementisEmptyjustliftmapmapOptionalmaterializemergemergemergemergemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnofTypeonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeWithonErrorReturnonErrorReturnItemonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryUntilretryWhensafeSubscribesequenceEqualsequenceEqualstartWithstartWithstartWithstartWithstartWithsubscribesubscribesubscribesubscribesubscribesubscribesubscribeActualsubscribeOnsubscribeWithswitchIfEmptyswitchIfEmptyswitchOnNextswitchOnNextDelayErrortakeUntiltakeUntiltesttesttimeIntervaltimeIntervaltimeIntervaltimeIntervaltimeouttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimertimertimestamptimestamptimestamptimestamptotoCompletionStagetoCompletionStagetoFlowabletoFuturetoObservabletoSingleunsafeCreateunsubscribeOnusingusingwrapzipzipzipzipzipzipzipzipzipzipArrayzipWith

Field Detail

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

Constructor Detail

MaybeZipIterableback to summary
public MaybeZipIterable(Iterable<? extends MaybeSource<? extends T>> sources, Function<? super Object[], ? extends R> zipper)

Method Detail

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

pack-priv final Class MaybeZipIterable.SingletonArrayFunc

extends Object
implements Function<T, R>
Class Inheritance
  • java.lang.Object
  • io.reactivex.rxjava3.internal.operators.maybe.MaybeZipIterable.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