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 typeR
- 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 sourcePublisher
.
-
-
Constructor Summary
Constructors Constructor Description AbstractFlowableWithUpstream(Flowable<T> source)
Constructs a FlowableSource wrapping the given non-null (verified) source Publisher.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.reactivestreams.Publisher<T>
source()
Returns the source Publisher.-
Methods inherited from class io.reactivex.rxjava3.core.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
-
-
-
-
Method Detail
-
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 interfaceHasUpstreamPublisher<T>
- Returns:
- the source Publisher
-
-