hu.akarnokd.reactive4java.reactive

Class Delay.OnFinish<T>

java.lang.Object

hu.akarnokd.reactive4java.util.DefaultRunnable

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

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

Type Parameters:

T - the element type

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

Delay

public static class Delay.OnFinish<T>
extends Delay.DelayedObservation<T>

Deliver a finish() event.

Field Summary

Fields inherited from class hu.akarnokd.reactive4java.reactive.Delay.DelayedObservation

observer, queue

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

lock

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	onRun2() The delivery method.

Methods inherited from class hu.akarnokd.reactive4java.reactive.Delay.DelayedObservation

onRun

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

Constructor Detail

OnFinish

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

Constructor.

Parameters:

lock - the lock

queue - the delay-queue

observer - the observer to delay to

c - the close handler to stop the entire operation

Method Detail

onRun2

public void onRun2()

Description copied from class: Delay.DelayedObservation

The delivery method.

Specified by:

onRun2 in class Delay.DelayedObservation<T>