hu.akarnokd.reactive4java.reactive

Class Delay.OnNext<T>

java.lang.Object

hu.akarnokd.reactive4java.util.DefaultRunnable

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

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

Type Parameters:

T - the element type

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

Delay

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

Deliver a next() value.

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
OnNext(java.util.concurrent.locks.Lock lock, java.util.concurrent.BlockingQueue<java.io.Closeable> queue, Observer<? super T> observer, T value) 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

OnNext

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

Constructor.

Parameters:

lock - the lock

queue - the delay-queue

observer - the observer to delay to

value - the value to deliver

Method Detail

onRun2

public void onRun2()

Description copied from class: Delay.DelayedObservation

The delivery method.

Specified by:

onRun2 in class Delay.DelayedObservation<T>