Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.disposables | |
io.reactivex.internal.observers | |
io.reactivex.internal.operators.completable | |
io.reactivex.internal.operators.maybe | |
io.reactivex.internal.operators.mixed | |
io.reactivex.internal.operators.observable | |
io.reactivex.internal.operators.single | |
io.reactivex.internal.util | |
io.reactivex.observers |
Default wrappers and implementations for Observer-based consumer classes and interfaces,
including disposable and resource-tracking variants and
the
TestObserver that allows unit testing
Observable -, Single -, Maybe -
and Completable -based flows. |
io.reactivex.plugins |
Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers. |
io.reactivex.subjects |
Classes representing so-called hot sources, aka subjects, that implement a base reactive class and
the respective consumer type at once to allow forms of multicasting events to multiple
consumers as well as consuming another base reactive type of their kind.
|
Modifier and Type | Method and Description |
---|---|
<E extends Observer<? super T>> |
Observable.subscribeWith(E observer)
Subscribes a given Observer (subclass) to this Observable and returns the given
Observer as is.
|
Modifier and Type | Method and Description |
---|---|
Observer<? super Upstream> |
ObservableOperator.apply(Observer<? super Downstream> observer)
Applies a function to the child Observer and returns a new parent Observer.
|
Modifier and Type | Method and Description |
---|---|
Observer<? super Upstream> |
ObservableOperator.apply(Observer<? super Downstream> observer)
Applies a function to the child Observer and returns a new parent Observer.
|
void |
Observable.blockingSubscribe(Observer<? super T> observer)
Subscribes to the source and calls the
Observer methods on the current thread. |
Observable<T> |
Observable.doOnEach(Observer<? super T> observer)
Modifies the source ObservableSource so that it notifies an Observer for each item and terminal event it emits.
|
void |
Observable.safeSubscribe(Observer<? super T> observer)
Subscribes to the current Observable and wraps the given Observer into a SafeObserver
(if not already a SafeObserver) that
deals with exceptions thrown by a misbehaving Observer (that doesn't follow the
Reactive-Streams specification).
|
void |
ObservableSource.subscribe(Observer<? super T> observer)
Subscribes the given Observer to this ObservableSource instance.
|
void |
Observable.subscribe(Observer<? super T> observer) |
protected abstract void |
Observable.subscribeActual(Observer<? super T> observer)
Operator implementations (both source and intermediate) should implement this method that
performs the necessary business logic and handles the incoming
Observer s. |
Modifier and Type | Method and Description |
---|---|
static void |
EmptyDisposable.complete(Observer<?> observer) |
static void |
EmptyDisposable.error(Throwable e,
Observer<?> observer) |
Modifier and Type | Class and Description |
---|---|
class |
BasicFuseableObserver<T,R>
Base class for a fuseable intermediate observer.
|
class |
BlockingBaseObserver<T> |
class |
BlockingFirstObserver<T>
Blocks until the upstream signals its first value or completes.
|
class |
BlockingLastObserver<T>
Blocks until the upstream signals its last value or completes.
|
class |
BlockingObserver<T> |
class |
DeferredScalarObserver<T,R>
A fuseable Observer that can generate 0 or 1 resulting value.
|
class |
DisposableLambdaObserver<T> |
class |
ForEachWhileObserver<T> |
class |
FutureObserver<T>
An Observer + Future that expects exactly one upstream value and provides it
via the (blocking) Future API.
|
class |
InnerQueuedObserver<T>
Subscriber that can fuse with the upstream and calls a support interface
whenever an event is available.
|
class |
LambdaObserver<T> |
class |
QueueDrainObserver<T,U,V>
Abstract base class for subscribers that hold another subscriber, a queue
and requires queue-drain behavior.
|
Modifier and Type | Field and Description |
---|---|
protected Observer<? super V> |
QueueDrainObserver.downstream |
protected Observer<? super T> |
DeferredScalarDisposable.downstream
The target of the events.
|
protected Observer<? super R> |
BasicFuseableObserver.downstream
The downstream subscriber.
|
Modifier and Type | Method and Description |
---|---|
void |
QueueDrainObserver.accept(Observer<? super V> a,
U v) |
Constructor and Description |
---|
BasicFuseableObserver(Observer<? super R> downstream)
Construct a BasicFuseableObserver by wrapping the given subscriber.
|
DeferredScalarDisposable(Observer<? super T> downstream)
Constructs a DeferredScalarDisposable by wrapping the Observer.
|
DeferredScalarObserver(Observer<? super R> downstream)
Creates a DeferredScalarObserver instance and wraps a downstream Observer.
|
DisposableLambdaObserver(Observer<? super T> actual,
Consumer<? super Disposable> onSubscribe,
Action onDispose) |
QueueDrainObserver(Observer<? super V> actual,
SimplePlainQueue<U> queue) |
Modifier and Type | Method and Description |
---|---|
protected void |
CompletableToObservable.subscribeActual(Observer<? super T> observer) |
Modifier and Type | Method and Description |
---|---|
static <T> MaybeObserver<T> |
MaybeToObservable.create(Observer<? super T> downstream)
Creates a
MaybeObserver wrapper around a Observer . |
protected void |
MaybeFlatMapIterableObservable.subscribeActual(Observer<? super R> observer) |
protected void |
MaybeToObservable.subscribeActual(Observer<? super T> observer) |
Modifier and Type | Method and Description |
---|---|
protected void |
SingleFlatMapObservable.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableSwitchMapSingle.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableSwitchMapMaybe.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableConcatMapSingle.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableConcatMapMaybe.subscribeActual(Observer<? super R> observer) |
protected void |
MaybeFlatMapObservable.subscribeActual(Observer<? super R> observer) |
protected void |
CompletableAndThenObservable.subscribeActual(Observer<? super R> observer) |
Modifier and Type | Class and Description |
---|---|
class |
ObservableCache<T>
An observable which auto-connects to another observable, caches the elements
from that observable but allows terminating the connection and completing the cache.
|
static class |
ObservableGroupBy.GroupByObserver<T,K,V> |
class |
ObserverResourceWrapper<T> |
Modifier and Type | Method and Description |
---|---|
static <T> Action |
ObservableInternalHelper.observerOnComplete(Observer<T> observer) |
static <T> Consumer<Throwable> |
ObservableInternalHelper.observerOnError(Observer<T> observer) |
static <T> Consumer<T> |
ObservableInternalHelper.observerOnNext(Observer<T> observer) |
static <T> void |
ObservableBlockingSubscribe.subscribe(ObservableSource<? extends T> o,
Observer<? super T> observer)
Subscribes to the source and calls the Observer methods on the current thread.
|
void |
ObservableSequenceEqual.subscribeActual(Observer<? super Boolean> observer) |
protected void |
ObservableAny.subscribeActual(Observer<? super Boolean> t) |
protected void |
ObservableAll.subscribeActual(Observer<? super Boolean> t) |
void |
ObservableGroupBy.subscribeActual(Observer<? super GroupedObservable<K,V>> t) |
protected void |
ObservableRange.subscribeActual(Observer<? super Integer> o) |
void |
ObservableTimer.subscribeActual(Observer<? super Long> observer) |
protected void |
ObservableRangeLong.subscribeActual(Observer<? super Long> o) |
void |
ObservableIntervalRange.subscribeActual(Observer<? super Long> observer) |
void |
ObservableInterval.subscribeActual(Observer<? super Long> observer) |
void |
ObservableCount.subscribeActual(Observer<? super Long> t) |
void |
ObservableMaterialize.subscribeActual(Observer<? super Notification<T>> t) |
protected void |
ObservableNever.subscribeActual(Observer<? super Object> o) |
protected void |
ObservableEmpty.subscribeActual(Observer<? super Object> o) |
void |
ObservableWindowTimed.subscribeActual(Observer<? super Observable<T>> t) |
void |
ObservableWindowBoundarySupplier.subscribeActual(Observer<? super Observable<T>> observer) |
void |
ObservableWindowBoundarySelector.subscribeActual(Observer<? super Observable<T>> t) |
void |
ObservableWindowBoundary.subscribeActual(Observer<? super Observable<T>> observer) |
void |
ObservableWindow.subscribeActual(Observer<? super Observable<T>> t) |
void |
ObservableMapNotification.subscribeActual(Observer<? super ObservableSource<? extends R>> t) |
void |
ObservableZip.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableWithLatestFromMany.subscribeActual(Observer<? super R> observer) |
void |
ObservableWithLatestFrom.subscribeActual(Observer<? super R> t) |
void |
ObservableSwitchMap.subscribeActual(Observer<? super R> t) |
void |
ObservableScanSeed.subscribeActual(Observer<? super R> t) |
protected void |
ObservablePublishSelector.subscribeActual(Observer<? super R> observer) |
void |
ObservableLift.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableJoin.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableGroupJoin.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableFlattenIterable.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableFlatMapSingle.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableFlatMapMaybe.subscribeActual(Observer<? super R> observer) |
void |
ObservableDematerialize.subscribeActual(Observer<? super R> observer) |
protected void |
ObservableConcatMapEager.subscribeActual(Observer<? super R> observer) |
void |
ObservableCombineLatest.subscribeActual(Observer<? super R> observer) |
void |
ObservableUsing.subscribeActual(Observer<? super T> observer) |
void |
ObservableUnsubscribeOn.subscribeActual(Observer<? super T> t) |
protected void |
ObservableTimeoutTimed.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableTimeout.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableThrottleLatest.subscribeActual(Observer<? super T> observer) |
void |
ObservableThrottleFirstTimed.subscribeActual(Observer<? super T> t) |
void |
ObservableTakeWhile.subscribeActual(Observer<? super T> t) |
void |
ObservableTakeUntilPredicate.subscribeActual(Observer<? super T> observer) |
void |
ObservableTakeUntil.subscribeActual(Observer<? super T> child) |
void |
ObservableTakeLastTimed.subscribeActual(Observer<? super T> t) |
void |
ObservableTakeLastOne.subscribeActual(Observer<? super T> observer) |
void |
ObservableTakeLast.subscribeActual(Observer<? super T> t) |
protected void |
ObservableTake.subscribeActual(Observer<? super T> observer) |
void |
ObservableSwitchIfEmpty.subscribeActual(Observer<? super T> t) |
void |
ObservableSubscribeOn.subscribeActual(Observer<? super T> observer) |
void |
ObservableSkipWhile.subscribeActual(Observer<? super T> observer) |
void |
ObservableSkipUntil.subscribeActual(Observer<? super T> child) |
void |
ObservableSkipLastTimed.subscribeActual(Observer<? super T> t) |
void |
ObservableSkipLast.subscribeActual(Observer<? super T> observer) |
void |
ObservableSkip.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableSerialized.subscribeActual(Observer<? super T> observer) |
void |
ObservableScan.subscribeActual(Observer<? super T> t) |
void |
ObservableSampleWithObservable.subscribeActual(Observer<? super T> t) |
void |
ObservableSampleTimed.subscribeActual(Observer<? super T> t) |
protected void |
ObservableRetryWhen.subscribeActual(Observer<? super T> observer) |
void |
ObservableRetryPredicate.subscribeActual(Observer<? super T> observer) |
void |
ObservableRetryBiPredicate.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableReplay.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableRepeatWhen.subscribeActual(Observer<? super T> observer) |
void |
ObservableRepeatUntil.subscribeActual(Observer<? super T> observer) |
void |
ObservableRepeat.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableRefCount.subscribeActual(Observer<? super T> observer) |
protected void |
ObservablePublish.subscribeActual(Observer<? super T> observer) |
void |
ObservableOnErrorReturn.subscribeActual(Observer<? super T> t) |
void |
ObservableOnErrorNext.subscribeActual(Observer<? super T> t) |
protected void |
ObservableObserveOn.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableMergeWithSingle.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableMergeWithMaybe.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableMergeWithCompletable.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableJust.subscribeActual(Observer<? super T> observer) |
void |
ObservableIgnoreElements.subscribeActual(Observer<? super T> t) |
protected void |
ObservableHide.subscribeActual(Observer<? super T> o) |
void |
ObservableGenerate.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableFromUnsafeSource.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableFromPublisher.subscribeActual(Observer<? super T> o) |
void |
ObservableFromIterable.subscribeActual(Observer<? super T> observer) |
void |
ObservableFromFuture.subscribeActual(Observer<? super T> observer) |
void |
ObservableFromCallable.subscribeActual(Observer<? super T> observer) |
void |
ObservableFromArray.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableFlatMapCompletable.subscribeActual(Observer<? super T> observer) |
void |
ObservableFilter.subscribeActual(Observer<? super T> observer) |
void |
ObservableError.subscribeActual(Observer<? super T> observer) |
void |
ObservableElementAt.subscribeActual(Observer<? super T> t) |
protected void |
ObservableDoOnLifecycle.subscribeActual(Observer<? super T> observer) |
void |
ObservableDoOnEach.subscribeActual(Observer<? super T> t) |
protected void |
ObservableDoFinally.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableDoAfterNext.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableDistinctUntilChanged.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableDistinct.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableDetach.subscribeActual(Observer<? super T> observer) |
void |
ObservableDelaySubscriptionOther.subscribeActual(Observer<? super T> child) |
void |
ObservableDelay.subscribeActual(Observer<? super T> t) |
void |
ObservableDefer.subscribeActual(Observer<? super T> observer) |
void |
ObservableDebounceTimed.subscribeActual(Observer<? super T> t) |
void |
ObservableDebounce.subscribeActual(Observer<? super T> t) |
protected void |
ObservableCreate.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableConcatWithSingle.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableConcatWithMaybe.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableConcatWithCompletable.subscribeActual(Observer<? super T> observer) |
protected void |
ObservableCache.subscribeActual(Observer<? super T> t) |
void |
ObservableAutoConnect.subscribeActual(Observer<? super T> child) |
void |
ObservableAmb.subscribeActual(Observer<? super T> observer) |
void |
ObservableTimeInterval.subscribeActual(Observer<? super Timed<T>> t) |
void |
ObservableToList.subscribeActual(Observer<? super U> t) |
void |
ObservableMap.subscribeActual(Observer<? super U> t) |
void |
ObservableFlatMap.subscribeActual(Observer<? super U> t) |
void |
ObservableConcatMap.subscribeActual(Observer<? super U> observer) |
protected void |
ObservableCollect.subscribeActual(Observer<? super U> t) |
protected void |
ObservableBufferTimed.subscribeActual(Observer<? super U> t) |
protected void |
ObservableBufferExactBoundary.subscribeActual(Observer<? super U> t) |
protected void |
ObservableBufferBoundarySupplier.subscribeActual(Observer<? super U> t) |
protected void |
ObservableBufferBoundary.subscribeActual(Observer<? super U> t) |
protected void |
ObservableBuffer.subscribeActual(Observer<? super U> t) |
void |
ObservableZipIterable.subscribeActual(Observer<? super V> t) |
static <T,R> boolean |
ObservableScalarXMap.tryScalarXMapSubscribe(ObservableSource<T> source,
Observer<? super R> observer,
Function<? super T,? extends ObservableSource<? extends R>> mapper)
Tries to subscribe to a possibly Callable source's mapped ObservableSource.
|
Constructor and Description |
---|
GroupByObserver(Observer<? super GroupedObservable<K,V>> actual,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError) |
ObserverResourceWrapper(Observer<? super T> downstream) |
ScalarDisposable(Observer<? super T> observer,
T value) |
Modifier and Type | Method and Description |
---|---|
static <T> SingleObserver<T> |
SingleToObservable.create(Observer<? super T> downstream)
Creates a
SingleObserver wrapper around a Observer . |
protected void |
SingleFlatMapIterableObservable.subscribeActual(Observer<? super R> observer) |
void |
SingleToObservable.subscribeActual(Observer<? super T> observer) |
Modifier and Type | Class and Description |
---|---|
class |
EmptyComponent
Singleton implementing many interfaces as empty.
|
Modifier and Type | Method and Description |
---|---|
static <T> Observer<T> |
EmptyComponent.asObserver() |
Modifier and Type | Method and Description |
---|---|
static <T> boolean |
NotificationLite.accept(Object o,
Observer<? super T> observer)
Calls the appropriate Observer method based on the type of the notification.
|
<U> boolean |
AppendOnlyLinkedArrayList.accept(Observer<? super U> observer)
Interprets the contents as NotificationLite objects and calls
the appropriate Observer method.
|
void |
ObservableQueueDrain.accept(Observer<? super U> a,
T v)
Accept the value and return true if forwarded.
|
static <T> boolean |
NotificationLite.acceptFull(Object o,
Observer<? super T> observer)
Calls the appropriate Observer method based on the type of the notification.
|
static <T,U> boolean |
QueueDrainHelper.checkTerminated(boolean d,
boolean empty,
Observer<?> observer,
boolean delayError,
SimpleQueue<?> q,
Disposable disposable,
ObservableQueueDrain<T,U> qd) |
static <T,U> void |
QueueDrainHelper.drainLoop(SimplePlainQueue<T> q,
Observer<? super U> a,
boolean delayError,
Disposable dispose,
ObservableQueueDrain<T,U> qd) |
static void |
HalfSerializer.onComplete(Observer<?> observer,
AtomicInteger wip,
AtomicThrowable error)
Emits an onComplete signal or an onError signal with the given error or indicates
the concurrently running onNext should do that.
|
static void |
HalfSerializer.onError(Observer<?> observer,
Throwable ex,
AtomicInteger wip,
AtomicThrowable error)
Emits the given exception if possible or adds it to the given error container to
be emitted by a concurrent onNext if one is running.
|
static <T> void |
HalfSerializer.onNext(Observer<? super T> observer,
T value,
AtomicInteger wip,
AtomicThrowable error)
Emits the given value if possible and terminates if there was an onComplete or onError
while emitting, drops the value otherwise.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultObserver<T>
Abstract base implementation of an
Observer with support for cancelling a
subscription via DefaultObserver.cancel() (synchronously) and calls DefaultObserver.onStart()
when the subscription happens. |
class |
DisposableObserver<T>
An abstract
Observer that allows asynchronous cancellation by implementing Disposable. |
class |
ResourceObserver<T>
An abstract
Observer that allows asynchronous cancellation of its subscription and associated resources. |
class |
SafeObserver<T>
Wraps another Subscriber and ensures all onXXX methods conform the protocol
(except the requirement for serialized access).
|
class |
SerializedObserver<T>
Serializes access to the onNext, onError and onComplete methods of another Observer.
|
class |
TestObserver<T>
An Observer that records events and allows making assertions about them.
|
Modifier and Type | Method and Description |
---|---|
static <T> TestObserver<T> |
TestObserver.create(Observer<? super T> delegate)
Constructs a forwarding TestObserver.
|
Constructor and Description |
---|
SafeObserver(Observer<? super T> downstream)
Constructs a SafeObserver by wrapping the given actual Observer.
|
SerializedObserver(Observer<? super T> downstream)
Construct a SerializedObserver by wrapping the given actual Observer.
|
SerializedObserver(Observer<? super T> actual,
boolean delayError)
Construct a SerializedObserver by wrapping the given actual Observer and
optionally delaying the errors till all regular values have been emitted
from the internal buffer.
|
TestObserver(Observer<? super T> downstream)
Constructs a forwarding TestObserver.
|
Modifier and Type | Method and Description |
---|---|
static <T> Observer<? super T> |
RxJavaPlugins.onSubscribe(Observable<T> source,
Observer<? super T> observer)
Calls the associated hook function.
|
Modifier and Type | Method and Description |
---|---|
static BiFunction<? super Observable,? super Observer,? extends Observer> |
RxJavaPlugins.getOnObservableSubscribe()
Returns the current hook function.
|
static BiFunction<? super Observable,? super Observer,? extends Observer> |
RxJavaPlugins.getOnObservableSubscribe()
Returns the current hook function.
|
Modifier and Type | Method and Description |
---|---|
static <T> Observer<? super T> |
RxJavaPlugins.onSubscribe(Observable<T> source,
Observer<? super T> observer)
Calls the associated hook function.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaPlugins.setOnObservableSubscribe(BiFunction<? super Observable,? super Observer,? extends Observer> onObservableSubscribe)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnObservableSubscribe(BiFunction<? super Observable,? super Observer,? extends Observer> onObservableSubscribe)
Sets the specific hook function.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncSubject<T>
A Subject that emits the very last value followed by a completion event or the received error to Observers.
|
class |
BehaviorSubject<T>
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed
Observer . |
class |
PublishSubject<T>
A Subject that emits (multicasts) items to currently subscribed
Observer s and terminal events to current
or late Observer s. |
class |
ReplaySubject<T>
Replays events (in a configurable bounded or unbounded manner) to current and late
Observer s. |
class |
Subject<T>
Represents an
Observer and an Observable at the same time, allowing
multicasting events from a single source to multiple child Observer s. |
class |
UnicastSubject<T>
A Subject that queues up events until a single
Observer subscribes to it, replays
those events to it until the Observer catches up and then switches to relaying events live to
this single Observer until this UnicastSubject terminates or the Observer unsubscribes. |
Modifier and Type | Method and Description |
---|---|
protected void |
UnicastSubject.subscribeActual(Observer<? super T> observer) |
protected void |
ReplaySubject.subscribeActual(Observer<? super T> observer) |
protected void |
PublishSubject.subscribeActual(Observer<? super T> t) |
protected void |
BehaviorSubject.subscribeActual(Observer<? super T> observer) |
protected void |
AsyncSubject.subscribeActual(Observer<? super T> observer) |
Copyright © 2019. All rights reserved.