hu.akarnokd.reactive4java.util

Class OriginalObserverWrapper

java.lang.Object

hu.akarnokd.reactive4java.util.OriginalObserverWrapper

All Implemented Interfaces:

BaseObserver, Observer<java.lang.Object>

public class OriginalObserverWrapper
extends java.lang.Object
implements Observer<java.lang.Object>

Wraps a java-observer and its associated helper observable.

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.

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
OriginalObserverWrapper(java.util.Observable javaObservable, java.util.Observer javaObserver) Constructor.

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

javaObservable

protected final java.util.Observable javaObservable

The backing observable object.

javaObserver

protected final java.util.Observer javaObserver

The wrapped java-observer.

done

protected final java.util.concurrent.atomic.AtomicBoolean done

Indicate that the observer run to completion.

Constructor Detail

OriginalObserverWrapper

public OriginalObserverWrapper(@Nullable
                               java.util.Observable javaObservable,
                               @Nonnull
                               java.util.Observer javaObserver)

Constructor. Sets up the wrapping fields.

Parameters:

javaObservable - the backing observable

javaObserver - the java-observer to wrap

Method Detail

next

public void next(java.lang.Object value)

Description copied from interface: Observer

The next value is received.

Specified by:

next in interface Observer<java.lang.Object>

Parameters:

value - the next value

error

public void error(@Nonnull
                  java.lang.Throwable ex)

Description copied from interface: BaseObserver

An exception is received.

Specified by:

error in interface BaseObserver

Parameters:

ex - the exception

finish

public void finish()

Description copied from interface: BaseObserver

No more values to expect.

Specified by:

finish in interface BaseObserver

isDone

public boolean isDone()

Returns:

Returns true if this observer is terminated.