org.apache.reef.wake.rx.exception

Class ObserverCompletedException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

java.lang.IllegalStateException

org.apache.reef.wake.rx.exception.ObserverCompletedException

All Implemented Interfaces:

Serializable

public class ObserverCompletedException
extends IllegalStateException

It is illegal to call onError() or onCompleted() when a call to onNext() is still outstanding, or to call onNext(), onError() or onCompleted() after a call to onError() or onCompleted() has been dispatched. Observers may throw an ObserverCompleted exception whenever this API is violated. Violating the API leaves the Observer (and any resources that it holds) in an undefined state, and throwing ObserverCompleted exceptions is optional.

Callers receiving this exception should simply pass it up the stack to the Aura runtime. They should not attempt to forward it on to upstream or downstream stages. The easiest way to do this is to ignore the exception entirely.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ObserverCompletedException()

Method Summary

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ObserverCompletedException

public ObserverCompletedException()