Class AbstractFlowableWithUpstream<T,R>

java.lang.Object

io.reactivex.rxjava3.core.Flowable<R>

io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream<T,R>

Type Parameters:

T - the upstream value type

R - the output value type

All Implemented Interfaces:

HasUpstreamPublisher<T>, org.reactivestreams.Publisher<R>

Direct Known Subclasses:

FlowableAll, FlowableAny, FlowableBuffer, FlowableBufferBoundary, FlowableBufferExactBoundary, FlowableBufferTimed, FlowableCache, FlowableCollect, FlowableConcatMap, FlowableConcatMapEager, FlowableConcatMapScheduler, FlowableConcatWithCompletable, FlowableConcatWithMaybe, FlowableConcatWithSingle, FlowableCount, FlowableDebounce, FlowableDebounceTimed, FlowableDelay, FlowableDematerialize, FlowableDetach, FlowableDistinct, FlowableDistinctUntilChanged, FlowableDoAfterNext, FlowableDoFinally, FlowableDoOnEach, FlowableDoOnLifecycle, FlowableElementAt, FlowableFilter, FlowableFlatMap, FlowableFlatMapCompletable, FlowableFlatMapMaybe, FlowableFlatMapSingle, FlowableFlattenIterable, FlowableGroupBy, FlowableGroupJoin, FlowableHide, FlowableIgnoreElements, FlowableJoin, FlowableLift, FlowableMap, FlowableMapNotification, FlowableMaterialize, FlowableMergeWithCompletable, FlowableMergeWithMaybe, FlowableMergeWithSingle, FlowableObserveOn, FlowableOnBackpressureBuffer, FlowableOnBackpressureBufferStrategy, FlowableOnBackpressureDrop, FlowableOnBackpressureError, FlowableOnBackpressureLatest, FlowableOnBackpressureReduce, FlowableOnBackpressureReduceWith, FlowableOnErrorComplete, FlowableOnErrorNext, FlowableOnErrorReturn, FlowablePublishMulticast, FlowableReduce, FlowableRepeat, FlowableRepeatUntil, FlowableRepeatWhen, FlowableRetryBiPredicate, FlowableRetryPredicate, FlowableRetryWhen, FlowableSampleTimed, FlowableScan, FlowableScanSeed, FlowableSerialized, FlowableSingle, FlowableSkip, FlowableSkipLast, FlowableSkipLastTimed, FlowableSkipUntil, FlowableSkipWhile, FlowableSubscribeOn, FlowableSwitchIfEmpty, FlowableSwitchMap, FlowableTake, FlowableTakeLast, FlowableTakeLastOne, FlowableTakeLastTimed, FlowableTakeUntil, FlowableTakeUntilPredicate, FlowableTakeWhile, FlowableThrottleFirstTimed, FlowableThrottleLatest, FlowableTimeInterval, FlowableTimeout, FlowableTimeoutTimed, FlowableToList, FlowableUnsubscribeOn, FlowableWindow, FlowableWindowBoundary, FlowableWindowBoundarySelector, FlowableWindowTimed, FlowableWithLatestFrom, FlowableWithLatestFromMany, FlowableZipIterable

abstract class AbstractFlowableWithUpstream<T,R>
extends Flowable<R>
implements HasUpstreamPublisher<T>

Abstract base class for operators that take an upstream source Publisher.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Flowable<T>	source	The upstream source Publisher.

Constructor Summary

Constructors

Constructor	Description
AbstractFlowableWithUpstream(Flowable<T> source)	Constructs a FlowableSource wrapping the given non-null (verified) source Publisher.

Method Summary

Modifier and Type	Method	Description
final org.reactivestreams.Publisher<T>	source()	Returns the source Publisher.

Methods inherited from class Flowable

all, amb, ambArray, ambWith, any, blockingFirst, blockingFirst, blockingForEach, blockingForEach, blockingIterable, blockingIterable, blockingLast, blockingLast, blockingLatest, blockingMostRecent, blockingNext, blockingSingle, blockingSingle, blockingStream, blockingStream, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferSize, cache, cacheWithInitialCapacity, cast, collect, collect, collectInto, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatestArray, combineLatestArray, combineLatestArrayDelayError, combineLatestArrayDelayError, combineLatestDelayError, combineLatestDelayError, compose, concat, concat, concat, concat, concat, concat, concatArray, concatArrayDelayError, concatArrayEager, concatArrayEager, concatArrayEagerDelayError, concatArrayEagerDelayError, concatDelayError, concatDelayError, concatDelayError, concatEager, concatEager, concatEager, concatEager, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatMap, concatMap, concatMap, concatMapCompletable, concatMapCompletable, concatMapCompletableDelayError, concatMapCompletableDelayError, concatMapCompletableDelayError, concatMapDelayError, concatMapDelayError, concatMapDelayError, concatMapEager, concatMapEager, concatMapEagerDelayError, concatMapEagerDelayError, concatMapIterable, concatMapIterable, concatMapMaybe, concatMapMaybe, concatMapMaybeDelayError, concatMapMaybeDelayError, concatMapMaybeDelayError, concatMapSingle, concatMapSingle, concatMapSingleDelayError, concatMapSingleDelayError, concatMapSingleDelayError, concatMapStream, concatMapStream, concatWith, concatWith, concatWith, concatWith, contains, count, create, debounce, debounce, debounce, debounce, defaultIfEmpty, defer, delay, delay, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, dematerialize, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, distinctUntilChanged, doAfterNext, doAfterTerminate, doFinally, doOnCancel, doOnComplete, doOnEach, doOnEach, doOnError, doOnLifecycle, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elementAt, elementAt, elementAtOrError, empty, error, error, filter, first, firstElement, firstOrError, firstOrErrorStage, firstStage, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMapCompletable, flatMapCompletable, flatMapIterable, flatMapIterable, flatMapIterable, flatMapIterable, flatMapMaybe, flatMapMaybe, flatMapSingle, flatMapSingle, flatMapStream, flatMapStream, forEach, forEachWhile, forEachWhile, forEachWhile, fromAction, fromArray, fromCallable, fromCompletable, fromCompletionStage, fromFuture, fromFuture, fromIterable, fromMaybe, fromObservable, fromOptional, fromPublisher, fromRunnable, fromSingle, fromStream, fromSupplier, generate, generate, generate, generate, generate, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupJoin, hide, ignoreElements, interval, interval, interval, interval, intervalRange, intervalRange, isEmpty, join, just, just, just, just, just, just, just, just, just, just, last, lastElement, lastOrError, lastOrErrorStage, lastStage, lift, map, mapOptional, materialize, merge, merge, merge, merge, merge, merge, merge, merge, mergeArray, mergeArray, mergeArrayDelayError, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, mergeWith, mergeWith, mergeWith, never, observeOn, observeOn, observeOn, ofType, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureLatest, onBackpressureLatest, onBackpressureReduce, onBackpressureReduce, onErrorComplete, onErrorComplete, onErrorResumeNext, onErrorResumeWith, onErrorReturn, onErrorReturnItem, onTerminateDetach, parallel, parallel, parallel, publish, publish, publish, publish, range, rangeLong, rebatchRequests, reduce, reduce, reduceWith, repeat, repeat, repeatUntil, repeatWhen, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, retry, retry, retry, retry, retry, retryUntil, retryWhen, safeSubscribe, sample, sample, sample, sample, sample, sample, sample, scan, scan, scanWith, sequenceEqual, sequenceEqual, sequenceEqual, sequenceEqual, serialize, share, single, singleElement, singleOrError, singleOrErrorStage, singleStage, skip, skip, skip, skipLast, skipLast, skipLast, skipLast, skipLast, skipLast, skipUntil, skipWhile, sorted, sorted, startWith, startWith, startWith, startWith, startWithArray, startWithItem, startWithIterable, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeActual, subscribeOn, subscribeOn, subscribeWith, switchIfEmpty, switchMap, switchMap, switchMapCompletable, switchMapCompletableDelayError, switchMapDelayError, switchMapDelayError, switchMapMaybe, switchMapMaybeDelayError, switchMapSingle, switchMapSingleDelayError, switchOnNext, switchOnNext, switchOnNextDelayError, switchOnNextDelayError, take, take, take, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeUntil, takeUntil, takeWhile, test, test, test, throttleFirst, throttleFirst, throttleFirst, throttleLast, throttleLast, throttleLast, throttleLatest, throttleLatest, throttleLatest, throttleLatest, throttleLatest, throttleWithTimeout, throttleWithTimeout, throttleWithTimeout, timeInterval, timeInterval, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, timestamp, timestamp, timestamp, timestamp, to, toFuture, toList, toList, toList, toMap, toMap, toMap, toMultimap, toMultimap, toMultimap, toMultimap, toObservable, toSortedList, toSortedList, toSortedList, toSortedList, unsafeCreate, unsubscribeOn, using, using, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, withLatestFrom, withLatestFrom, withLatestFrom, withLatestFrom, withLatestFrom, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipArray, zipWith, zipWith, zipWith, zipWith

Methods inherited from class Object

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

Field Details

source

protected final Flowable<T> source

The upstream source Publisher.

Constructor Details

AbstractFlowableWithUpstream

AbstractFlowableWithUpstream(Flowable<T> source)

Constructs a FlowableSource wrapping the given non-null (verified) source Publisher.

Parameters:

source - the source (upstream) Publisher instance, not null (verified)

Method Details

source

public final org.reactivestreams.Publisher<T> source()

Description copied from interface: HasUpstreamPublisher

Returns the source Publisher.

This method is intended to discover the assembly graph of sequences.

Specified by:

source in interface HasUpstreamPublisher<T>

Returns:

the source Publisher