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-backpressured Observable source base interface, consumable via an Observer.
Since:
2.0