RxJava 2 2.2.21 · io.reactivex.internal.observers.BasicFuseableObserver

Modifier and Type	Field and Description
protected boolean	done Flag indicating no further onXXX event should be accepted.
protected final Observer<? super R>	downstream The downstream subscriber.
protected QueueDisposable<T>	qd The upstream's QueueDisposable if not null.
protected int	sourceMode Holds the established fusion mode of the upstream.
protected Disposable	upstream The upstream subscription.

Access	Constructor and Description
public	BasicFuseableObserver(Observer<? super R> the subscriber, not null (not verified) downstream) Construct a BasicFuseableObserver by wrapping the given subscriber.

Method Summary

Modifier and Type	Method and Description
protected void	afterDownstream() Override this to perform actions after the call to `actual.onSubscribe(this)` happened.
protected boolean	Returns: true if onSubscribe should continue with the call beforeDownstream() Override this to perform actions before the call `actual.onSubscribe(this)` happens.
public void	clear() Implements io.reactivex.internal.fuseable.SimpleQueue.clear. Removes all enqueued items from this queue.
public void	dispose() Implements io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
protected final void	fail(Throwable the throwable to rethrow or signal to the actual subscriber t) Rethrows the throwable if it is a fatal exception or calls `onError(Throwable)`.
public boolean	isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public boolean	isEmpty() Implements io.reactivex.internal.fuseable.SimpleQueue.isEmpty. Returns true if the queue is empty.
public final boolean	offer(R the value to enqueue, not null e) Implements io.reactivex.internal.fuseable.SimpleQueue.offer. Atomically enqueue a single.
public final boolean	offer(R the first value to enqueue, not null v1, R the second value to enqueue, not null v2) Implements io.reactivex.internal.fuseable.SimpleQueue.offer. Atomically enqueue two values.
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 final 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.
protected final int	Returns: the established fusion mode transitiveBoundaryFusion(int the fusion mode requested mode) Calls the upstream's QueueDisposable.requestFusion with the mode and saves the established mode in `sourceMode` if that mode doesn't have the `QueueDisposable#BOUNDARY` flag set.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

done	back to summary
protected boolean done Flag indicating no further onXXX event should be accepted.

downstream	back to summary
protected final Observer<? super R> downstream The downstream subscriber.

qd	back to summary
protected QueueDisposable<T> qd The upstream's QueueDisposable if not null.

sourceMode	back to summary
protected int sourceMode Holds the established fusion mode of the upstream.

upstream	back to summary
protected Disposable upstream The upstream subscription.

BasicFuseableObserver	back to summary
public BasicFuseableObserver(Observer<? super R> downstream) Construct a BasicFuseableObserver by wrapping the given subscriber. Parameters downstream:Observer<? super R> the subscriber, not null (not verified)

Method Detail

afterDownstream	back to summary
protected void afterDownstream() Override this to perform actions after the call to `actual.onSubscribe(this)` happened.

beforeDownstream back to summary

beforeDownstream	back to summary
protected boolean beforeDownstream() Override this to perform actions before the call `actual.onSubscribe(this)` happens. Returns:boolean true if onSubscribe should continue with the call

protected boolean beforeDownstream()

Override this to perform actions before the call actual.onSubscribe(this) happens.

Returns:boolean: true if onSubscribe should continue with the call

clear	back to summary
public void clear() Implements io.reactivex.internal.fuseable.SimpleQueue.clear. Doc from io.reactivex.internal.fuseable.SimpleQueue.clear. Removes all enqueued items from this queue. Annotations @Override

clear

back to summary

public void clear()

Implements io.reactivex.internal.fuseable.SimpleQueue.clear.

Doc from io.reactivex.internal.fuseable.SimpleQueue.clear.

Removes all enqueued items from this queue.

Annotations

@Override

dispose	back 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

dispose

back 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

fail back to summary

fail	back to summary
protected final void fail(Throwable t) Rethrows the throwable if it is a fatal exception or calls `onError(Throwable)`. Parameters t:Throwable the throwable to rethrow or signal to the actual subscriber

protected final void fail(Throwable t)

Rethrows the throwable if it is a fatal exception or calls onError(Throwable).

Parameters

t:Throwable: the throwable to rethrow or signal to the actual subscriber

isDisposed	back 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

isDisposed

back 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

isEmpty back to summary

isEmpty	back to summary
public boolean isEmpty() Implements io.reactivex.internal.fuseable.SimpleQueue.isEmpty. Doc from io.reactivex.internal.fuseable.SimpleQueue.isEmpty. Returns true if the queue is empty. Note however that due to potential fused functions in `poll()` it is possible this method returns false but then poll() returns null because the fused function swallowed the available item(s). Returns:boolean true if the queue is empty Annotations @Override

public boolean isEmpty()

Implements io.reactivex.internal.fuseable.SimpleQueue.isEmpty.

Doc from io.reactivex.internal.fuseable.SimpleQueue.isEmpty.

Returns true if the queue is empty.

Note however that due to potential fused functions in poll() it is possible this method returns false but then poll() returns null because the fused function swallowed the available item(s).

Returns:boolean

true if the queue is empty

Annotations

@Override

offer	back to summary
public final boolean offer(R e) Implements io.reactivex.internal.fuseable.SimpleQueue.offer. Doc from io.reactivex.internal.fuseable.SimpleQueue.offer. Atomically enqueue a single. Parameters e:R the value to enqueue, not null Returns:boolean true if successful, false if the value was not enqueued likely due to reaching the queue capacity) Annotations @Override

offer

back to summary

public final boolean offer(R e)

Implements io.reactivex.internal.fuseable.SimpleQueue.offer.

Doc from io.reactivex.internal.fuseable.SimpleQueue.offer.

Atomically enqueue a single.

Parameters

e:R: the value to enqueue, not null

Returns:boolean

true if successful, false if the value was not enqueued likely due to reaching the queue capacity)

Annotations

@Override

offer	back to summary
public final boolean offer(R v1, R v2) Implements io.reactivex.internal.fuseable.SimpleQueue.offer. Doc from io.reactivex.internal.fuseable.SimpleQueue.offer. Atomically enqueue two values. Parameters v1:R the first value to enqueue, not null v2:R the second value to enqueue, not null Returns:boolean true if successful, false if the value was not enqueued likely due to reaching the queue capacity) Annotations @Override

offer

back to summary

public final boolean offer(R v1, R v2)

Implements io.reactivex.internal.fuseable.SimpleQueue.offer.

Doc from io.reactivex.internal.fuseable.SimpleQueue.offer.

Atomically enqueue two values.

Parameters

v1:R: the first value to enqueue, not null
v2:R: the second value to enqueue, not null

Returns:boolean

true if successful, false if the value was not enqueued likely due to reaching the queue capacity)

Annotations

@Override

onComplete back to summary

onComplete	back 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

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

onError back to summary

onError	back 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

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

onSubscribe back to summary

onSubscribe	back to summary
public final 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 @SuppressWarnings:unchecked @Override

public final 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

@SuppressWarnings:unchecked
@Override

transitiveBoundaryFusion back to summary

transitiveBoundaryFusion	back to summary
protected final int transitiveBoundaryFusion(int mode) Calls the upstream's QueueDisposable.requestFusion with the mode and saves the established mode in `sourceMode` if that mode doesn't have the `QueueDisposable#BOUNDARY` flag set. If the upstream doesn't support fusion (`qd` is null), the method returns `QueueDisposable#NONE`. Parameters mode:int the fusion mode requested Returns:int the established fusion mode

protected final int transitiveBoundaryFusion(int mode)

Calls the upstream's QueueDisposable.requestFusion with the mode and saves the established mode in sourceMode if that mode doesn't have the QueueDisposable#BOUNDARY flag set.

If the upstream doesn't support fusion (qd is null), the method returns QueueDisposable#NONE.

Parameters

mode:int: the fusion mode requested

Returns:int

the established fusion mode

public abstract Class BasicFuseableObserver<T, R>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail