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 viasource()
method.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description @NonNull org.reactivestreams.Publisher<T>
source()
Returns the source Publisher.
-