brainslug.flow.execution.node

Class EventNodeExecutor

java.lang.Object

brainslug.flow.execution.node.DefaultNodeExecutor<EventNodeExecutor,EventDefinition>

brainslug.flow.execution.node.EventNodeExecutor

All Implemented Interfaces:

FlowNodeExecutor<EventDefinition>

public class EventNodeExecutor
extends DefaultNodeExecutor<EventNodeExecutor,EventDefinition>

Field Summary

Fields inherited from class brainslug.flow.execution.node.DefaultNodeExecutor

tokenOperations

Constructor Summary

Constructors

Constructor and Description
EventNodeExecutor(AsyncTriggerStore asyncTriggerStore, PredicateEvaluator predicateEvaluator)

Method Summary

Modifier and Type	Method and Description
protected void	addTimersIfDefined(EventDefinition eventDefinition, ExecutionContext execution)
FlowNodeExecutionResult	execute(EventDefinition eventDefinition, ExecutionContext execution)
protected long	getCurrentTime()
protected boolean	predicateIsFulfilled(PredicateDefinition eventPredicate, ExecutionContext execution)
protected boolean	waitingForSignal(EventDefinition eventDefinition, TriggerContext trigger)

Methods inherited from class brainslug.flow.execution.node.DefaultNodeExecutor

removeIncomingTokens, takeAll, takeNone, withTokenOperations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventNodeExecutor

public EventNodeExecutor(AsyncTriggerStore asyncTriggerStore,
                         PredicateEvaluator predicateEvaluator)

Method Detail

execute

public FlowNodeExecutionResult execute(EventDefinition eventDefinition,
                                       ExecutionContext execution)

Specified by:

execute in interface FlowNodeExecutor<EventDefinition>

Overrides:

execute in class DefaultNodeExecutor<EventNodeExecutor,EventDefinition>

addTimersIfDefined

protected void addTimersIfDefined(EventDefinition eventDefinition,
                                  ExecutionContext execution)

getCurrentTime

protected long getCurrentTime()

waitingForSignal

protected boolean waitingForSignal(EventDefinition eventDefinition,
                                   TriggerContext trigger)

predicateIsFulfilled

protected boolean predicateIsFulfilled(PredicateDefinition eventPredicate,
                                       ExecutionContext execution)