package components
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
-
class
AtomicExecutor extends StatelessComponent[Assignment, Future[Seq[AnyMsg]]]
Runs AtomicProcesses and handles all necessary communication with the various stateless workflow actors.
- case class PreExecutionException(t: Throwable) extends Throwable with Product with Serializable
-
class
Reducer extends StatelessComponent[ReduceRequest, Seq[AnyMsg]]
Takes New Process Instances -> Updated Workflow State, and either an immediate result or a list of requested computations Separated from StatelessExecActor to ensure the WorkflowState message is actually posted before the tasks are executed.
- class ResultListener extends StatelessComponent[PiiLog, Unit] with PiObservable[ObjectId] with SimplePiObservable[ObjectId]
- abstract class StatelessComponent[In, Out] extends Function[In, Out]
Value Members
- object ResultListener