public interface WorkflowSystem
Modifier and Type | Interface and Description |
---|---|
static interface |
WorkflowSystem.Operation<X,T extends WorkflowSystem.OperationCompleted>
An operation which returns a success result object
|
static interface |
WorkflowSystem.OperationCompleted<T>
Indicates an operation completed, supplies a new set of state data to update the mutable state with
|
static interface |
WorkflowSystem.OperationResult<D,T extends WorkflowSystem.OperationCompleted<D>,X extends WorkflowSystem.Operation<D,T>>
Return type which contains either a success result, or a failure throwable, and includes the original
operation
|
static interface |
WorkflowSystem.SharedData<T>
Manages shared data, consumes results of operations, and produces input for subsequent operations
|
Modifier and Type | Method and Description |
---|---|
boolean |
isInterrupted() |
<D,T extends WorkflowSystem.OperationCompleted<D>,X extends WorkflowSystem.Operation<D,T>> |
processOperations(java.util.Set<X> operations,
WorkflowSystem.SharedData<D> shared)
Process the operations and return results when all runnable operations are complete.
|
<D,T extends WorkflowSystem.OperationCompleted<D>,X extends WorkflowSystem.Operation<D,T>> java.util.Set<WorkflowSystem.OperationResult<D,T,X>> processOperations(java.util.Set<X> operations, WorkflowSystem.SharedData<D> shared)
T
- success result of an operationX
- operation classD
- shared data typeoperations
- operationsboolean isInterrupted()
processOperations(Set, SharedData)
stopped due to interruption