Class MaybeDelaySubscriptionOtherPublisher<T,U>

java.lang.Object

io.reactivex.rxjava3.core.Maybe<T>

io.reactivex.rxjava3.internal.operators.maybe.MaybeDelaySubscriptionOtherPublisher<T,U>

Type Parameters:

T - the main value type

U - the other value type

All Implemented Interfaces:

MaybeSource<T>, HasUpstreamMaybeSource<T>

public final class MaybeDelaySubscriptionOtherPublisher<T,U>
extends Maybe<T>

Delay the subscription to the main Maybe until the other signals an item or completes.

Field Summary

Fields

Modifier and Type	Field	Description
protected final MaybeSource<T>	source

Constructor Summary

Constructors

Constructor	Description
MaybeDelaySubscriptionOtherPublisher(MaybeSource<T> source, org.reactivestreams.Publisher<U> other)

Method Summary

Modifier and Type	Method	Description
final MaybeSource<T>	source()	Returns the upstream source of this Maybe.
protected void	subscribeActual(MaybeObserver<? super T> observer)	Implement this method in subclasses to handle the incoming MaybeObservers.

Methods inherited from class Maybe

amb, ambArray, ambWith, blockingGet, blockingGet, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, cache, cast, compose, concat, concat, concat, concat, concat, concat, concatArray, concatArrayDelayError, concatArrayEager, concatArrayEagerDelayError, concatDelayError, concatDelayError, concatDelayError, concatEager, concatEager, concatEager, concatEager, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatMap, concatMapCompletable, concatMapSingle, concatWith, contains, count, create, defaultIfEmpty, defer, delay, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, dematerialize, doAfterSuccess, doAfterTerminate, doFinally, doOnComplete, doOnDispose, doOnError, doOnEvent, doOnLifecycle, doOnSubscribe, doOnSuccess, doOnTerminate, empty, error, error, filter, flatMap, flatMap, flatMap, flatMapCompletable, flatMapObservable, flatMapPublisher, flatMapSingle, flattenAsFlowable, flattenAsObservable, flattenStreamAsFlowable, flattenStreamAsObservable, fromAction, fromCallable, fromCompletable, fromCompletionStage, fromFuture, fromFuture, fromObservable, fromOptional, fromPublisher, fromRunnable, fromSingle, fromSupplier, hide, ignoreElement, isEmpty, just, lift, map, mapOptional, materialize, merge, merge, merge, merge, merge, merge, merge, mergeArray, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, never, observeOn, ofType, onErrorComplete, onErrorComplete, onErrorResumeNext, onErrorResumeWith, onErrorReturn, onErrorReturnItem, onTerminateDetach, repeat, repeat, repeatUntil, repeatWhen, retry, retry, retry, retry, retry, retryUntil, retryWhen, safeSubscribe, sequenceEqual, sequenceEqual, startWith, startWith, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, switchIfEmpty, switchOnNext, switchOnNextDelayError, takeUntil, takeUntil, test, test, timeInterval, timeInterval, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, timestamp, timestamp, timestamp, timestamp, to, toCompletionStage, toCompletionStage, toFlowable, toFuture, toObservable, toSingle, unsafeCreate, unsubscribeOn, using, using, wrap, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipArray, zipWith

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

source

protected final MaybeSource<T> source

Constructor Details

MaybeDelaySubscriptionOtherPublisher

public MaybeDelaySubscriptionOtherPublisher(MaybeSource<T> source,
 org.reactivestreams.Publisher<U> other)

Method Details

subscribeActual

protected void subscribeActual(MaybeObserver<? super T> observer)

Description copied from class: Maybe

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 Maybe.subscribe(MaybeObserver) before this method gets called.

Specified by:

subscribeActual in class Maybe<T>

Parameters:

observer - the MaybeObserver to handle, not null

source

public final MaybeSource<T> source()

Description copied from interface: HasUpstreamMaybeSource

Returns the upstream source of this Maybe.

Allows discovering the chain of observables.

Specified by:

source in interface HasUpstreamMaybeSource<T>

Returns:

the source MaybeSource