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
-
Method Details
-
source
Returns the source Publisher.This method is intended to discover the assembly graph of sequences.
- Returns:
- the source Publisher
-