Package io.reactivex.rxjava3.internal.fuseable

Interface HasUpstreamPublisher<T>

Type Parameters:
T - the value type
All Known Implementing Classes:
AbstractFlowableWithUpstream, 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, FlowablePublish, FlowablePublishMulticast, FlowableReduce, FlowableReduceMaybe, FlowableRepeat, FlowableRepeatUntil, FlowableRepeatWhen, FlowableReplay, 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
public interface HasUpstreamPublisher<@NonNull T>
Interface indicating the implementor has an upstream Publisher-like source available via source() method.

  • Method Summary

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

  • Method Details

    • source

      @NonNull @NonNull org.reactivestreams.Publisher<T> source()
      Returns the source Publisher.

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

      Returns:
      the source Publisher