Top Description Fields Constructors Methods
io.reactivex.observers

public final Class SerializedObserver<T>

extends Object
implements Observer<T>, Disposable
Class Inheritance
All Implemented Interfaces
io.reactivex.disposables.Disposable, io.reactivex.Observer
Type Parameters
<T>
the value type
Imports
io.reactivex.Observer, io.reactivex.annotations.*, io.reactivex.disposables.Disposable, io.reactivex.internal.disposables.DisposableHelper, io.reactivex.internal.util.*, io.reactivex.plugins.RxJavaPlugins
Serializes access to the onNext, onError and onComplete methods of another Observer.

Note that onSubscribe(Disposable) is not serialized in respect of the other methods so make sure the onSubscribe() is called with a non-null Disposable before any of the other methods are called.

The implementation assumes that the actual Observer's methods don't throw.

Field Summary

Modifier and TypeField and Description
pack-priv final boolean
delayError

pack-priv volatile boolean
done

pack-priv final Observer<? super T>
downstream

pack-priv boolean
emitting

pack-priv AppendOnlyLinkedArrayList<Object>
queue

pack-priv Disposable
upstream

Constructor Summary

AccessConstructor and Description
public
SerializedObserver(Observer<? super T>
the actual Observer, not null (not verified)
downstream)

Construct a SerializedObserver by wrapping the given actual Observer.

public
SerializedObserver(Observer<? super T>
the actual Observer, not null (not verified)
actual, boolean
if true, errors are emitted after regular values have been emitted
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.

Method Summary

Modifier and TypeMethod and Description
public void
dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.
pack-priv void
emitLoop()

public boolean
isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.
public void
onComplete()

Implements io.reactivex.Observer.onComplete.

Notifies the Observer that the Observable has finished sending push-based notifications.
public void
onError(Throwable
the exception encountered by the Observable
t)

Implements io.reactivex.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.
public void
onNext(T
the item emitted by the Observable
t)

Implements io.reactivex.Observer.onNext.

Provides the Observer with a new item to observe.
public void
onSubscribe(Disposable
the Disposable instance whose Disposable#dispose() can be called anytime to cancel the connection
d)

Implements io.reactivex.Observer.onSubscribe.

Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within onNext(Object)) and asynchronous manner.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

delayErrorback to summary
pack-priv final boolean delayError
doneback to summary
pack-priv volatile boolean done
downstreamback to summary
pack-priv final Observer<? super T> downstream
emittingback to summary
pack-priv boolean emitting
queueback to summary
pack-priv AppendOnlyLinkedArrayList<Object> queue
upstreamback to summary
pack-priv Disposable upstream

Constructor Detail

SerializedObserverback to summary
public SerializedObserver(Observer<? super T> downstream)

Construct a SerializedObserver by wrapping the given actual Observer.

Parameters
downstream:Observer<? super T>

the actual Observer, not null (not verified)

SerializedObserverback to summary
public 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.

Parameters
actual:Observer<? super T>

the actual Observer, not null (not verified)

delayError:boolean

if true, errors are emitted after regular values have been emitted

Method Detail

disposeback to summary
public void dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Doc from io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations
@Override
emitLoopback to summary
pack-priv void emitLoop()
isDisposedback to summary
public boolean isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

Doc from io.reactivex.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations
@Override
onCompleteback to summary
public void onComplete()

Implements io.reactivex.Observer.onComplete.

Doc from io.reactivex.Observer.onComplete.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations
@Override
onErrorback to summary
public void onError(Throwable t)

Implements io.reactivex.Observer.onError.

Doc from io.reactivex.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onComplete.

Parameters
t:Throwable

the exception encountered by the Observable

Annotations
@Override
onNextback to summary
public void onNext(T t)

Implements io.reactivex.Observer.onNext.

Doc from io.reactivex.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onComplete or onError.

Parameters
t:T

the item emitted by the Observable

Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Disposable d)

Implements io.reactivex.Observer.onSubscribe.

Doc from io.reactivex.Observer.onSubscribe.

Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within onNext(Object)) and asynchronous manner.

Parameters
d:Disposable

the Disposable instance whose Disposable#dispose() can be called anytime to cancel the connection

Annotations
@Override