public abstract Class DeferredScalarSubscriberSafe<T, R>

Class Inheritance

java.lang.Object
rx.Subscriber
rx.internal.operators.DeferredScalarSubscriber
rx.internal.operators.DeferredScalarSubscriberSafe

Known Direct Subclasses

rx.internal.operators.OnSubscribeCollect.CollectSubscriber, rx.internal.operators.OnSubscribeToMap.ToMapSubscriber, rx.internal.operators.OnSubscribeToMultimap.ToMultimapSubscriber

Type Parameters

<T>: source value type
<R>: result value type

Imports

rx.Subscriber, rx.plugins.RxJavaHooks

Supplements DeferredScalarSubscriber with defensive behaviour that ensures no emissions occur after a terminal event. If onError is called more than once then errors after the first are reported to RxJavaHooks.onError.

Field Summary

Modifier and Type	Field and Description
protected boolean	done

Inherited from rx.internal.operators.DeferredScalarSubscriber:: actual HAS_REQUEST_HAS_VALUE HAS_REQUEST_NO_VALUE hasValue NO_REQUEST_HAS_VALUE NO_REQUEST_NO_VALUE state value

Constructor Summary

Access	Constructor and Description
public	DeferredScalarSubscriberSafe(Subscriber<? super R> actual)

Method Summary

Modifier and Type	Method and Description
public void	onCompleted() Overrides rx.internal.operators.DeferredScalarSubscriber.onCompleted. Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable ex) Overrides rx.internal.operators.DeferredScalarSubscriber.onError. Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.

Inherited from rx.internal.operators.DeferredScalarSubscriber:: complete complete downstreamRequest setProducer setupDownstream subscribeTo

Field Detail

done	back to summary
protected boolean done

Constructor Detail

DeferredScalarSubscriberSafe	back to summary
public DeferredScalarSubscriberSafe(Subscriber<? super R> actual)

Method Detail

onCompleted back to summary

onCompleted	back to summary
public void onCompleted() Overrides rx.internal.operators.DeferredScalarSubscriber.onCompleted. Implements rx.Observer.onCompleted. Doc from rx.Observer.onCompleted. 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 onCompleted()

Overrides rx.internal.operators.DeferredScalarSubscriber.onCompleted.

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

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 ex) Overrides rx.internal.operators.DeferredScalarSubscriber.onError. Implements rx.Observer.onError. Doc from rx.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 `onCompleted`. Parameters ex:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable ex)

Overrides rx.internal.operators.DeferredScalarSubscriber.onError.

Implements rx.Observer.onError.

Doc from rx.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 onCompleted.

Parameters

ex:Throwable: the exception encountered by the Observable

Annotations

@Override