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

public final Class MaybeZipIterable<T, R>

extends Maybe<R>
Class Inheritance
Imports
java.util.Arrays, io.reactivex.*, io.reactivex.exceptions.Exceptions, io.reactivex.functions.Function, io.reactivex.internal.disposables.EmptyDisposable, io.reactivex.internal.functions.ObjectHelper, io.reactivex.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>
the MaybeObserver to handle, not null
observer)

Implements abstract io.reactivex.Maybe.subscribeActual.

Implement this method in subclasses to handle the incoming MaybeObservers.
Inherited from io.reactivex.Maybe:
ambambArrayambWithasblockingGetblockingGetcachecastcomposeconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatArrayEagerconcatDelayErrorconcatDelayErrorconcatEagerconcatEagerconcatMapconcatWithcontainscountcreatedefaultIfEmptydeferdelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondoAfterSuccessdoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnErrordoOnEventdoOnSubscribedoOnSuccessdoOnTerminateemptyerrorerrorfilterflatMapflatMapflatMapflatMapCompletableflatMapObservableflatMapPublisherflatMapSingleflatMapSingleElementflattenAsFlowableflattenAsObservablefromActionfromCallablefromCompletablefromFuturefromFuturefromRunnablefromSinglehideignoreElementisEmptyjustliftmapmaterializemergemergemergemergemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnofTypeonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeNextonErrorReturnonErrorReturnItemonExceptionResumeNextonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryUntilretryWhensequenceEqualsequenceEqualsubscribesubscribesubscribesubscribesubscribesubscribeOnsubscribeWithswitchIfEmptyswitchIfEmptytakeUntiltakeUntiltesttesttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimertimertotoFlowabletoObservabletoSingletoSingleunsafeCreateunsubscribeOnusingusingwrapzipzipzipzipzipzipzipzipzipzipArrayzipWith

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)

Implements abstract io.reactivex.Maybe.subscribeActual.

Doc from io.reactivex.Maybe.subscribeActual.

Implement this method in subclasses to handle the incoming MaybeObservers.

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

Parameters
observer:MaybeObserver<? super R>

the MaybeObserver to handle, not null

Annotations
@Override
io.reactivex.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.internal.operators.maybe.MaybeZipIterable.SingletonArrayFunc
All Implemented Interfaces
io.reactivex.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.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 Exception

Implements io.reactivex.functions.Function.apply.

Doc from io.reactivex.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
Exception:
on error