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 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