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

public final Class SingleZipIterable<T, R>

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

Implements abstract io.reactivex.Single.subscribeActual.

Implement this method in subclasses to handle the incoming SingleObservers.
Inherited from io.reactivex.Single:
ambambArrayambWithasblockingGetcachecastcomposeconcatconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayEagerconcatEagerconcatEagerconcatWithcontainscontainscreatedeferdelaydelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondelaySubscriptiondematerializedoAfterSuccessdoAfterTerminatedoFinallydoOnDisposedoOnErrordoOnEventdoOnSubscribedoOnSuccessdoOnTerminateequalserrorerrorfilterflatMapflatMapCompletableflatMapMaybeflatMapObservableflatMapPublisherflattenAsFlowableflattenAsObservablefromCallablefromFuturefromFuturefromFuturefromFuturefromObservablefromPublisherhideignoreElementjustliftmapmaterializemergemergemergemergemergemergemergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnonErrorResumeNextonErrorResumeNextonErrorReturnonErrorReturnItemonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryWhensubscribesubscribesubscribesubscribesubscribesubscribeOnsubscribeWithtakeUntiltakeUntiltakeUntiltesttesttimeouttimeouttimeouttimeouttimertimertotoCompletabletoFlowabletoFuturetoMaybetoObservableunsafeCreateunsubscribeOnusingusingwrapzipzipzipzipzipzipzipzipzipzipArrayzipWith

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)

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
io.reactivex.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.internal.operators.single.SingleZipIterable.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