public interface ReactorListener
Reactor.execute(Executor, ReactorListener)
.
The callback happens by using the threads of Executor
, which means these callbacks
can occur concurrently. The callee is responsible for synchronization, if that's desired.Modifier and Type | Interface and Description |
---|---|
static class |
ReactorListener.Aggregator
Bundles multiple listeners into one.
|
Modifier and Type | Field and Description |
---|---|
static ReactorListener |
NOOP |
Modifier and Type | Method and Description |
---|---|
void |
onAttained(Milestone milestone)
Indicates that the following milestone was attained.
|
void |
onTaskCompleted(Task t)
Notifies that the execution of the task is about to finish.
|
void |
onTaskFailed(Task t,
Throwable err,
boolean fatal)
Notifies that the execution of the task have failed with an exception.
|
void |
onTaskStarted(Task t)
Notifies that the execution of the task is about to start.
|
static final ReactorListener NOOP
void onTaskStarted(Task t)
void onTaskCompleted(Task t)
onTaskStarted(Task)
.void onTaskFailed(Task t, Throwable err, boolean fatal)
void onAttained(Milestone milestone)
Copyright © 2014. All rights reserved.