hu.akarnokd.reactive4java.util

Class LockedObserver<T>

java.lang.Object

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

Type Parameters:

T - the element type

All Implemented Interfaces:

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

public class LockedObserver<T>
extends java.lang.Object
implements Observer<T>, java.io.Closeable

Class to wrap an observer's method calls via a lock to prevent concurrent callback of its methods. The class implements the Closeable interface and forwards this close call to the wrapped observer, if it supports Closeable as well (otherwise, its no-op).

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.locks.Lock	lock The lock object.
protected Observer<? super T>	observer The wrapped observer.

Constructor Summary

Constructors

Constructor and Description
LockedObserver(Observer<? super T> o) Constructor, sets the wrapped observer and uses a fair ReentrantLock.
LockedObserver(Observer<? super T> o, java.util.concurrent.locks.Lock l) Constructor, sets the wrapped observer and uses the provided lock.

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.
java.util.concurrent.locks.Lock	getLock()
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

observer

protected final Observer<? super T> observer

The wrapped observer.

lock

protected final java.util.concurrent.locks.Lock lock

The lock object.

Constructor Detail

LockedObserver

public LockedObserver(@Nonnull
                      Observer<? super T> o)

Constructor, sets the wrapped observer and uses a fair ReentrantLock.

Parameters:

o - the observer

LockedObserver

public LockedObserver(@Nonnull
                      Observer<? super T> o,
                      @Nonnull
                      java.util.concurrent.locks.Lock l)

Constructor, sets the wrapped observer and uses the provided lock.

Parameters:

o - the observer

l - the lock

Method Detail

getLock

public java.util.concurrent.locks.Lock getLock()

Returns:

the lock object

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

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