Object -
streams
:
AbstractOperatorProcessor
Abstract processor encapsulating operator functions.
Methods
promote
Promotes the StreamEvent
to the previous processor.
evict
Evicts the StreamEvent
from current state branch.
Fields
- stateEvents LinkedList
-
list of fulfilled states
Promotes the StreamEvent
to the previous processor.
Parameters
- stateEvent StreamEvent
-
event to promote
- processorAlias string?
-
alias for the calling processor, for identification purposes (lhs, rhs).
Evicts the StreamEvent
from current state branch.
Parameters
- stateEvent StreamEvent
-
event to promote
- processorAlias string?
-
alias for the calling processor, for identification purposes (lhs, rhs).