hu.akarnokd.reactive4java.util

Class SafeObserver<T>

java.lang.Object

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

Type Parameters:

T - the element type

All Implemented Interfaces:

BaseObserver, Observer<T>

public class SafeObserver<T>
extends java.lang.Object
implements Observer<T>

A simple wrapping observer which closes the specified handle in case of error or finish message, or an exception raised by the wrapped next.

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.Closeable	handle The close handle.
protected Observer<? super T>	o The observer.

Constructor Summary

Constructors

Constructor and Description
SafeObserver(Observer<? super T> o, java.io.Closeable handle) 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.
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

o

protected final Observer<? super T> o

The observer.

handle

protected final java.io.Closeable handle

The close handle.

Constructor Detail

SafeObserver

public SafeObserver(@Nonnull
                    Observer<? super T> o,
                    @Nonnull
                    java.io.Closeable handle)

Constructor.

Parameters:

o - the observer to wrap

handle - the close handle

Method Detail

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

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