hu.akarnokd.reactive4java.util

Class DefaultCloseableObserver<T>

java.lang.Object

hu.akarnokd.reactive4java.util.DefaultCloseableObserver<T>

Type Parameters:

T - the observed element type

All Implemented Interfaces:

BaseObserver, Cancelable, CloseableObserver<T>, Observer<T>, java.io.Closeable, java.lang.AutoCloseable

public class DefaultCloseableObserver<T>
extends java.lang.Object
implements CloseableObserver<T>, Cancelable

Class to wrap a raw observer and provide it with enforced event-sequence constraints and closeability.

• Fixed order: next()* [error()|finish()]?
• After finish or terminate, subsequent calls to the base methods are ignored

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	completed The completion indicator.
protected Observer<T>	observer The wrapped observer.

Constructor Summary

Constructors

Constructor and Description
DefaultCloseableObserver(Observer<T> o) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
void	error(java.lang.Throwable ex) An exception is received.
void	finish() No more values to expect.
boolean	isClosed()
void	next(T 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

completed

protected boolean completed

The completion indicator.

observer

protected final Observer<T> observer

The wrapped observer.

Constructor Detail

DefaultCloseableObserver

public DefaultCloseableObserver(@Nonnull
                                Observer<T> o)

Constructor. Initializes the observer field.

Parameters:

o - the observer to wrap

Method Detail

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

next

public void next(T value)

Description copied from interface: Observer

The next value is received.

Specified by:

next in interface Observer<T>

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

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Cancelable

Returns:

true if the object has been closed.