reactor.bus.support

Class NotifyConsumer<T>

java.lang.Object

reactor.bus.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 Object
implements Consumer<T>

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

Author:

Jon Brisbin, Stephane Maldini

Constructor Summary

Constructors

Constructor and Description
NotifyConsumer(Object notifyKey, Bus<?> 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(Object notifyKey,
                      Bus<?> 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.