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.
Represents a basic, non-backpressured
Observable
source base interface,
consumable via an Observer
.- Since:
- 2.0
-
Method Summary
-
Method Details
-
subscribe
Subscribes the givenObserver
to thisObservableSource
instance.- Parameters:
observer
- theObserver
, notnull
- Throws:
NullPointerException
- ifobserver
isnull
-