Modifier and Type | Interface and Description |
---|---|
static interface |
TaskChainTasks.AsyncExecutingFirstTask<R> |
static interface |
TaskChainTasks.AsyncExecutingGenericTask |
static interface |
TaskChainTasks.AsyncExecutingTask<R,A>
A task that does not return immediately.
|
static interface |
TaskChainTasks.FirstTask<R>
A task that expects no input, and returns a value.
|
static interface |
TaskChainTasks.FutureFirstTask<R>
A Task that returns a future to be completed later.
|
static interface |
TaskChainTasks.FutureGenericTask
A generic task that expects no input or output, but uses a future style API
to control moving to the next task.
|
static interface |
TaskChainTasks.FutureTask<R,A>
A task that returns a future to be completed later.
|
static interface |
TaskChainTasks.GenericTask
A task that expects no input or output
|
static interface |
TaskChainTasks.LastTask<A>
A task that expects input, but will not provide a response.
|
Modifier and Type | Method and Description |
---|---|
BiConsumer<Exception,TaskChainTasks.Task<?,?>> |
TaskChainFactory.getDefaultErrorHandler()
Returns the default error handler that will be used by all chains created by this factory,
if they do not suspply their own error handler.
|
BiConsumer<Exception,TaskChainTasks.Task<?,?>> |
TaskChain.getErrorHandler() |
Modifier and Type | Method and Description |
---|---|
<R> TaskChain<R> |
TaskChain.async(TaskChainTasks.Task<R,T> task)
TaskChain#sync(Task) but ran off main thread |
<R> TaskChain<List<R>> |
TaskChain.asyncFutures(TaskChainTasks.Task<List<CompletableFuture<R>>,T> task)
Executes a Task off the Main thread that provides a list of Futures, and holds processing
of the chain until all of the futures completes.
|
<R> TaskChain<R> |
TaskChain.current(TaskChainTasks.Task<R,T> task)
TaskChain#sync(Task) but ran on current thread the Chain was created on |
<R> TaskChain<List<R>> |
TaskChain.currentFutures(TaskChainTasks.Task<List<CompletableFuture<R>>,T> task)
Executes a Task on the current thread that provides a list of Futures, and holds processing
of the chain until all of the futures completes.
|
<R> TaskChain<R> |
TaskChain.sync(TaskChainTasks.Task<R,T> task)
Execute task on main thread, with the last returned input, returning an output
|
<R> TaskChain<List<R>> |
TaskChain.syncFutures(TaskChainTasks.Task<List<CompletableFuture<R>>,T> task)
Executes a Task on the Main thread that provides a list of Futures, and holds processing
of the chain until all of the futures completes.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskChain.execute(BiConsumer<Exception,TaskChainTasks.Task<?,?>> errorHandler)
Finished adding tasks, begins executing them, with an error handler
|
void |
TaskChain.execute(Consumer<Boolean> done,
BiConsumer<Exception,TaskChainTasks.Task<?,?>> errorHandler)
Finished adding tasks, begins executing them with a done notifier and error handler
|
void |
TaskChain.execute(Runnable done,
BiConsumer<Exception,TaskChainTasks.Task<?,?>> errorHandler)
Finished adding tasks, begins executing them with a done notifier and error handler
|
void |
TaskChainFactory.setDefaultErrorHandler(BiConsumer<Exception,TaskChainTasks.Task<?,?>> errorHandler)
Sets the default error handler used for all chains created by this factory,
if they do not supply their own error handler.
|
void |
TaskChain.setErrorHandler(BiConsumer<Exception,TaskChainTasks.Task<?,?>> errorHandler)
Changes the error handler for this chain
|
Copyright © 2018. All rights reserved.