reactor.event.dispatch

Class AbstractLifecycleDispatcher.Task

java.lang.Object

reactor.event.dispatch.AbstractLifecycleDispatcher.Task

All Implemented Interfaces:

java.lang.Runnable, Recyclable

Direct Known Subclasses:

AbstractMultiThreadDispatcher.MultiThreadTask, AbstractSingleThreadDispatcher.SingleThreadTask

Enclosing class:

AbstractLifecycleDispatcher

public abstract class AbstractLifecycleDispatcher.Task
extends java.lang.Object
implements java.lang.Runnable, Recyclable

Field Summary

Fields

Modifier and Type	Field and Description
protected Consumer<?>	completionConsumer
protected Registry<Consumer<? extends Event<?>>>	consumerRegistry
protected Consumer<java.lang.Throwable>	errorConsumer
protected Event<?>	event
protected EventRouter	eventRouter
protected java.lang.Object	key

Constructor Summary

Constructors

Constructor and Description
Task()

Method Summary

Modifier and Type	Method and Description
void	recycle() Free any internal resources and reset the state of the object to enable reuse.
AbstractLifecycleDispatcher.Task	setCompletionConsumer(Consumer<?> completionConsumer)
AbstractLifecycleDispatcher.Task	setConsumerRegistry(Registry<Consumer<? extends Event<?>>> consumerRegistry)
AbstractLifecycleDispatcher.Task	setErrorConsumer(Consumer<java.lang.Throwable> errorConsumer)
AbstractLifecycleDispatcher.Task	setEvent(Event<?> event)
AbstractLifecycleDispatcher.Task	setEventRouter(EventRouter eventRouter)
AbstractLifecycleDispatcher.Task	setKey(java.lang.Object key)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Field Detail

key

protected volatile java.lang.Object key

consumerRegistry

protected volatile Registry<Consumer<? extends Event<?>>> consumerRegistry

event

protected volatile Event<?> event

completionConsumer

protected volatile Consumer<?> completionConsumer

errorConsumer

protected volatile Consumer<java.lang.Throwable> errorConsumer

eventRouter

protected volatile EventRouter eventRouter

Constructor Detail

Task

public Task()

Method Detail

setKey

public AbstractLifecycleDispatcher.Task setKey(java.lang.Object key)

setConsumerRegistry

public AbstractLifecycleDispatcher.Task setConsumerRegistry(Registry<Consumer<? extends Event<?>>> consumerRegistry)

setEvent

public AbstractLifecycleDispatcher.Task setEvent(Event<?> event)

setCompletionConsumer

public AbstractLifecycleDispatcher.Task setCompletionConsumer(Consumer<?> completionConsumer)

setErrorConsumer

public AbstractLifecycleDispatcher.Task setErrorConsumer(Consumer<java.lang.Throwable> errorConsumer)

setEventRouter

public AbstractLifecycleDispatcher.Task setEventRouter(EventRouter eventRouter)

recycle

public void recycle()

Description copied from interface: Recyclable

Free any internal resources and reset the state of the object to enable reuse.

Specified by:

recycle in interface Recyclable