hu.akarnokd.reactive4java.util

Class ReactiveObservableWrapper<T>

java.lang.Object

java.util.Observable

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

Type Parameters:

T - the wrapped observable's element type

All Implemented Interfaces:

Observable<T>

public class ReactiveObservableWrapper<T>
extends java.util.Observable
implements Observable<T>

Wrapper for an existing reactive-observable and maps its features to the java-observable.

Removes all registered java-observers in case an error or finish is received.

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected Observable<T>	observable The wrapped reactive-observable.
protected java.util.Map<java.util.Observer,java.io.Closeable>	registry The registry for observer-closeable pairs.

Constructor Summary

Constructors

Constructor and Description
ReactiveObservableWrapper(Observable<T> observable) Constructor.

Method Summary

Modifier and Type	Method and Description
void	addObserver(java.util.Observer o)
int	countObservers()
void	deleteObserver(java.util.Observer o)
void	deleteObservers()
void	notifyObservers(java.lang.Object arg)
java.io.Closeable	register(java.util.Observer observer) Registers a java-observer and returns a handle to it.
java.io.Closeable	register(Observer<? super T> observer) Registers an observer for the notification of Ts.

Methods inherited from class java.util.Observable

clearChanged, hasChanged, notifyObservers, setChanged

Methods inherited from class java.lang.Object

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

Field Detail

observable

protected final Observable<T> observable

The wrapped reactive-observable.

registry

protected final java.util.Map<java.util.Observer,java.io.Closeable> registry

The registry for observer-closeable pairs.

Constructor Detail

ReactiveObservableWrapper

public ReactiveObservableWrapper(@Nonnull
                                 Observable<T> observable)

Constructor.

Parameters:

observable - the reactive-observable to wrap

Method Detail

addObserver

public void addObserver(java.util.Observer o)

Overrides:

addObserver in class java.util.Observable

deleteObserver

public void deleteObserver(java.util.Observer o)

Overrides:

deleteObserver in class java.util.Observable

deleteObservers

public void deleteObservers()

Overrides:

deleteObservers in class java.util.Observable

countObservers

public int countObservers()

Overrides:

countObservers in class java.util.Observable

notifyObservers

public void notifyObservers(java.lang.Object arg)

Overrides:

notifyObservers in class java.util.Observable

register

@Nonnull
public java.io.Closeable register(@Nonnull
                                            Observer<? super T> observer)

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<T>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider

register

@Nonnull
public java.io.Closeable register(@Nonnull
                                            java.util.Observer observer)

Registers a java-observer and returns a handle to it. The observer can be unregistered via this handle or the regular deleteObserver().

The convenience method is to have symmetric means for both observer kinds to interact with this observable.

Parameters:

observer - the observer to register

Returns:

the unregistration handle