hu.akarnokd.reactive4java.util

Class Producer.State<U>

java.lang.Object

hu.akarnokd.reactive4java.util.Producer.State<U>

Type Parameters:

U - the element type

All Implemented Interfaces:

Action1<java.io.Closeable>

Enclosing class:

Producer<T>

protected static class Producer.State<U>
extends java.lang.Object
implements Action1<java.io.Closeable>

The internal state of the observer registrations.

Field Summary

Fields

Modifier and Type	Field and Description
Observer<? super U>	observer The reference to the observer.
SingleCloseable	registration The closeable handle for the registration.
SingleCloseable	sink The closeable handle to the value sink.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	State()

Method Summary

Modifier and Type	Method and Description
void	invoke(java.io.Closeable value) The action body.

Methods inherited from class java.lang.Object

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

Field Detail

sink

public SingleCloseable sink

The closeable handle to the value sink.

registration

public SingleCloseable registration

The closeable handle for the registration.

observer

public Observer<? super U> observer

The reference to the observer.

Constructor Detail

State

protected State()

Method Detail

invoke

public void invoke(java.io.Closeable value)

Description copied from interface: Action1

The action body.

Specified by:

invoke in interface Action1<java.io.Closeable>

Parameters:

value - the value