reactor.core.support

Class NotifyConsumer<T>

java.lang.Object

reactor.core.support.NotifyConsumer<T>

Type Parameters:

T - the type of the values that the consumer can accept

All Implemented Interfaces:

Consumer<T>

public class NotifyConsumer<T>
extends java.lang.Object
implements Consumer<T>

A Consumer that notifies an observable of each value that it has accepted.

Constructor Summary

Constructors

Constructor and Description
NotifyConsumer(java.lang.Object notifyKey, Observable observable) Creates a new NotifyConsumer that will notify the given observable using the given notifyKey.

Method Summary

Modifier and Type	Method and Description
void	accept(T t) Execute the logic of the action, accepting the given parameter.

Methods inherited from class java.lang.Object

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

Constructor Detail

NotifyConsumer

public NotifyConsumer(java.lang.Object notifyKey,
                      Observable observable)

Creates a new NotifyConsumer that will notify the given observable using the given notifyKey. If notifyKey is null, observable will be notified without a key.

Parameters:

notifyKey - The notification key, may be null

observable - The observable to notify. May not be null

Method Detail

accept

public void accept(T t)

Description copied from interface: Consumer

Execute the logic of the action, accepting the given parameter.

Specified by:

accept in interface Consumer<T>

Parameters:

t - The parameter to pass to the consumer.