| Package | Description |
|---|---|
| com.ebay.bascomtask.core |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ConsumerTask
Function tasks added through 'fn()' methods on
Orchestrator allow CompletableFuture tasks to
be created from lambda expressions that do not return a value. |
interface |
SupplierTask<R>
Function tasks added through 'fn()' methods on
Orchestrator allow CompletableFuture tasks to
be created from lambda expressions that supply a return value. |
| Modifier and Type | Class and Description |
|---|---|
static class |
ConsumerTask.ConsumerTask1<IN>
An ConsumerTask that takes 1 argument.
|
static class |
ConsumerTask.ConsumerTask2<IN1,IN2>
An ConsumerTask that takes 2 arguments.
|
static class |
SupplierTask.SupplierTask0<R>
An SupplierTask that takes no arguments.
|
static class |
SupplierTask.SupplierTask1<IN,R>
An SupplierTask that takes 1 argument.
|
static class |
SupplierTask.SupplierTask2<IN1,IN2,R>
An SupplierTask that takes 2 arguments.
|
| Modifier and Type | Method and Description |
|---|---|
<BASE,SUB extends TaskInterface<BASE>> |
Engine.task(SUB t) |
<BASE,SUB extends TaskInterface<BASE>> |
Orchestrator.task(SUB userTask)
Creates a task wrapper around any user POJO with the requirement that that POJO implements an interface X
that in turn implements TaskInterface<X>.The result is a wrapper object that has the same signature
as its pojo argument, such that any CompletableFuture-returning task methods invoked on this wrapper are not
executed right away --they will be executed if/when any read operation on the returned CompletableFuture is
performed or by passing that CompletableFuture to
Orchestrator.execute(CompletionStage[]) or any of its variants. |
| Modifier and Type | Method and Description |
|---|---|
TaskInterface<?> |
TaskRun.getTask()
Returns the user task pojo if there is one.
|
Copyright © 2021. All rights reserved.