Package io.reactivex.rxjava3.core
Interface ObservableSource<T>
-
- Type Parameters:
T
- the element type
- All Known Implementing Classes:
AbstractObservableWithUpstream
,AsyncSubject
,BehaviorSubject
,CompletableAndThenObservable
,CompletableToObservable
,ConnectableObservable
,GroupedObservable
,MaybeFlatMapIterableObservable
,MaybeFlatMapObservable
,MaybeFlattenStreamAsObservable
,MaybeToObservable
,Observable
,ObservableAll
,ObservableAmb
,ObservableAny
,ObservableAutoConnect
,ObservableBuffer
,ObservableBufferBoundary
,ObservableBufferExactBoundary
,ObservableBufferTimed
,ObservableCache
,ObservableCollect
,ObservableCollectWithCollector
,ObservableCombineLatest
,ObservableConcatMap
,ObservableConcatMapEager
,ObservableConcatMapMaybe
,ObservableConcatMapScheduler
,ObservableConcatMapSingle
,ObservableConcatWithCompletable
,ObservableConcatWithMaybe
,ObservableConcatWithSingle
,ObservableCount
,ObservableCreate
,ObservableDebounce
,ObservableDebounceTimed
,ObservableDefer
,ObservableDelay
,ObservableDelaySubscriptionOther
,ObservableDematerialize
,ObservableDetach
,ObservableDistinct
,ObservableDistinctUntilChanged
,ObservableDoAfterNext
,ObservableDoFinally
,ObservableDoOnEach
,ObservableDoOnLifecycle
,ObservableElementAt
,ObservableEmpty
,ObservableError
,ObservableFilter
,ObservableFlatMap
,ObservableFlatMapCompletable
,ObservableFlatMapMaybe
,ObservableFlatMapSingle
,ObservableFlatMapStream
,ObservableFlattenIterable
,ObservableFromAction
,ObservableFromArray
,ObservableFromCallable
,ObservableFromCompletable
,ObservableFromCompletionStage
,ObservableFromFuture
,ObservableFromIterable
,ObservableFromPublisher
,ObservableFromRunnable
,ObservableFromStream
,ObservableFromSupplier
,ObservableFromUnsafeSource
,ObservableGenerate
,ObservableGroupBy
,ObservableGroupBy.GroupedUnicast
,ObservableGroupBy.State
,ObservableGroupJoin
,ObservableHide
,ObservableIgnoreElements
,ObservableInterval
,ObservableIntervalRange
,ObservableJoin
,ObservableJust
,ObservableLift
,ObservableMap
,ObservableMapNotification
,ObservableMapOptional
,ObservableMaterialize
,ObservableMergeWithCompletable
,ObservableMergeWithMaybe
,ObservableMergeWithSingle
,ObservableNever
,ObservableObserveOn
,ObservableOnErrorComplete
,ObservableOnErrorNext
,ObservableOnErrorReturn
,ObservablePublish
,ObservablePublishSelector
,ObservableRange
,ObservableRangeLong
,ObservableRefCount
,ObservableRepeat
,ObservableRepeatUntil
,ObservableRepeatWhen
,ObservableReplay
,ObservableReplay.MulticastReplay
,ObservableReplay.ReplaySource
,ObservableRetryBiPredicate
,ObservableRetryPredicate
,ObservableRetryWhen
,ObservableSampleTimed
,ObservableSampleWithObservable
,ObservableScalarXMap.ScalarXMapObservable
,ObservableScan
,ObservableScanSeed
,ObservableSequenceEqual
,ObservableSerialized
,ObservableSkip
,ObservableSkipLast
,ObservableSkipLastTimed
,ObservableSkipUntil
,ObservableSkipWhile
,ObservableSubscribeOn
,ObservableSwitchIfEmpty
,ObservableSwitchMap
,ObservableSwitchMapMaybe
,ObservableSwitchMapSingle
,ObservableTake
,ObservableTakeLast
,ObservableTakeLastOne
,ObservableTakeLastTimed
,ObservableTakeUntil
,ObservableTakeUntilPredicate
,ObservableTakeWhile
,ObservableThrottleFirstTimed
,ObservableThrottleLatest
,ObservableTimeInterval
,ObservableTimeout
,ObservableTimeoutTimed
,ObservableTimer
,ObservableToList
,ObservableUnsubscribeOn
,ObservableUsing
,ObservableWindow
,ObservableWindowBoundary
,ObservableWindowBoundarySelector
,ObservableWindowBoundarySelector.WindowBoundaryMainObserver.WindowEndObserverIntercept
,ObservableWindowSubscribeIntercept
,ObservableWindowTimed
,ObservableWithLatestFrom
,ObservableWithLatestFromMany
,ObservableZip
,ObservableZipIterable
,PublishSubject
,ReplaySubject
,SerializedSubject
,SingleFlatMapIterableObservable
,SingleFlatMapObservable
,SingleFlattenStreamAsObservable
,SingleToObservable
,Subject
,UnicastSubject
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface ObservableSource<@NonNull T>
Represents a basic, non-backpressuredObservable
source base interface, consumable via anObserver
.- Since:
- 2.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
subscribe(@NonNull Observer<? super @NonNull T> observer)
Subscribes the givenObserver
to thisObservableSource
instance.
-