reactor.bus.support

Class EventConsumer<T>

java.lang.Object

reactor.bus.support.EventConsumer<T>

Type Parameters:

T - the type of the event that can be handled by the consumer and the type that can be handled by the delegate

All Implemented Interfaces:

Consumer<Event<T>>

public class EventConsumer<T>
extends Object
implements Consumer<Event<T>>

Simple Consumer implementation that pulls the data from an Event and passes it to a delegate Consumer.

Author:

Jon Brisbin, Stephane Maldini

Constructor Summary

Constructors

Constructor and Description
EventConsumer(Consumer<T> delegate) Creates a new EventConsumer that will pass event data to the given delegate.

Method Summary

Modifier and Type	Method and Description
void	accept(Event<T> ev) 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

EventConsumer

public EventConsumer(@Nonnull
                     Consumer<T> delegate)

Creates a new EventConsumer that will pass event data to the given delegate.

Parameters:

delegate - The delegate consumer

Method Detail

accept

public void accept(Event<T> ev)

Description copied from interface: Consumer

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

Specified by:

accept in interface Consumer<Event<T>>

Parameters:

ev - The parameter to pass to the consumer.