reactor.core.dispatch

Class AbstractLifecycleDispatcher.Task

java.lang.Object

reactor.core.dispatch.AbstractLifecycleDispatcher.Task

All Implemented Interfaces:

Runnable, Recyclable

Direct Known Subclasses:

MultiThreadDispatcher.MultiThreadTask, SingleThreadDispatcher.SingleThreadTask

Enclosing class:

AbstractLifecycleDispatcher

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

Field Summary

Fields

Modifier and Type	Field and Description
protected Object	data
protected Consumer<Throwable>	errorConsumer
protected Consumer	eventConsumer

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	setData(Object data)
AbstractLifecycleDispatcher.Task	setErrorConsumer(Consumer<Throwable> errorConsumer)
AbstractLifecycleDispatcher.Task	setEventConsumer(Consumer<?> eventConsumer)

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

data

protected volatile Object data

eventConsumer

protected volatile Consumer eventConsumer

errorConsumer

protected volatile Consumer<Throwable> errorConsumer

Constructor Detail

Task

public Task()

Method Detail

setData

public AbstractLifecycleDispatcher.Task setData(Object data)

setEventConsumer

public AbstractLifecycleDispatcher.Task setEventConsumer(Consumer<?> eventConsumer)

setErrorConsumer

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

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