public class OriginalObserverWrapper extends java.lang.Object implements Observer<java.lang.Object>
The class features a done state for the case if the observer runs to completion before its close handle is registered. Using the isDone() state, unwanted retention of finished observers can be avoided in java-observable wrappers.
| Modifier and Type | Field and Description |
|---|---|
protected java.util.concurrent.atomic.AtomicBoolean |
done
Indicate that the observer run to completion.
|
protected java.util.Observable |
javaObservable
The backing observable object.
|
protected java.util.Observer |
javaObserver
The wrapped java-observer.
|
| Constructor and Description |
|---|
OriginalObserverWrapper(java.util.Observable javaObservable,
java.util.Observer javaObserver)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
error(java.lang.Throwable ex)
An exception is received.
|
void |
finish()
No more values to expect.
|
boolean |
isDone() |
void |
next(java.lang.Object value)
The next value is received.
|
protected final java.util.Observable javaObservable
protected final java.util.Observer javaObserver
protected final java.util.concurrent.atomic.AtomicBoolean done
public OriginalObserverWrapper(@Nullable
java.util.Observable javaObservable,
@Nonnull
java.util.Observer javaObserver)
javaObservable - the backing observablejavaObserver - the java-observer to wrappublic void next(java.lang.Object value)
Observerpublic void error(@Nonnull
java.lang.Throwable ex)
BaseObservererror in interface BaseObserverex - the exceptionpublic void finish()
BaseObserverfinish in interface BaseObserverpublic boolean isDone()