hu.akarnokd.reactive4java.reactive

Class Delay.DelayedObservation<T>

java.lang.Object

hu.akarnokd.reactive4java.util.DefaultRunnable

hu.akarnokd.reactive4java.reactive.Delay.DelayedObservation<T>

Type Parameters:

T - the element type

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

Delay.OnError, Delay.OnFinish, Delay.OnNext

Enclosing class:

Delay

public abstract static class Delay.DelayedObservation<T>
extends DefaultRunnable

Base class for the delayed observation delivery.

Field Summary

Fields

Modifier and Type	Field and Description
protected Observer<? super T>	observer The observer.
protected java.util.concurrent.BlockingQueue<java.io.Closeable>	queue The queue.

Fields inherited from class hu.akarnokd.reactive4java.util.DefaultRunnable

lock

Constructor Summary

Constructors

Constructor and Description
DelayedObservation(java.util.concurrent.locks.Lock lock, java.util.concurrent.BlockingQueue<java.io.Closeable> queue, Observer<? super T> observer) Constructor.

Method Summary

Modifier and Type	Method and Description
void	onRun() The alternative run method, which will be called by the original run() method under lock.
abstract void	onRun2() The delivery method.

Methods inherited from class hu.akarnokd.reactive4java.util.DefaultRunnable

cancel, cancelled, run

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 observer.

queue

protected final java.util.concurrent.BlockingQueue<java.io.Closeable> queue

The queue.

Constructor Detail

DelayedObservation

public DelayedObservation(@Nonnull
                          java.util.concurrent.locks.Lock lock,
                          @Nonnull
                          java.util.concurrent.BlockingQueue<java.io.Closeable> queue,
                          @Nonnull
                          Observer<? super T> observer)

Constructor.

Parameters:

lock - the lock

queue - the queue for deregistration

observer - the observer to interact with

Method Detail

onRun

public final void onRun()

Description copied from class: DefaultRunnable

The alternative run method, which will be called by the original run() method under lock.

Specified by:

onRun in class DefaultRunnable

onRun2

public abstract void onRun2()

The delivery method.