reactor.event.support

Class CallbackEvent<T>

java.lang.Object

reactor.event.Event<T>

reactor.event.support.CallbackEvent<T>

Type Parameters:

T - the type of the event payload

All Implemented Interfaces:

java.io.Serializable, Recyclable

public class CallbackEvent<T>
extends Event<T>

Simple Event implementation that attaches a callback to an Event and passes it to a delegate Consumer.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class reactor.event.Event

Event.Headers

Constructor Summary

Constructors

Constructor and Description
CallbackEvent(Event.Headers headers, T data, Consumer callback)
CallbackEvent(Event.Headers headers, T data, Consumer callback, Consumer<java.lang.Throwable> throwableConsumer)
CallbackEvent(T data, Consumer callback)

Method Summary

Modifier and Type	Method and Description
void	callback() Trigger callback with current payload
<X> Event<X>	copy(X data) Create a copy of this event, reusing same headers and replyTo

Methods inherited from class reactor.event.Event

consumeError, copy, getData, getErrorConsumer, getHeaders, getId, getKey, getReplyTo, override, recycle, setData, setKey, setReplyTo, toString, wrap, wrap

Methods inherited from class java.lang.Object

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

Constructor Detail

CallbackEvent

public CallbackEvent(T data,
                     Consumer callback)

CallbackEvent

public CallbackEvent(Event.Headers headers,
                     T data,
                     Consumer callback)

CallbackEvent

public CallbackEvent(Event.Headers headers,
                     T data,
                     Consumer callback,
                     Consumer<java.lang.Throwable> throwableConsumer)

Method Detail

copy

public <X> Event<X> copy(X data)

Description copied from class: Event

Create a copy of this event, reusing same headers and replyTo

Overrides:

copy in class Event<T>

Returns:

event copy

callback

public void callback()

Trigger callback with current payload