Object - streams : CompoundPatternProcessor

Processor to perform compound stream operations.

Constructor

__init

(int? withinTimeMillis)

  • withinTimeMillis int?

Methods

Fields

  • withinTimeMillis int?
  • time from initial state to current state should be within this time

process

(StreamEvent event, string? processorAlias)

returns [boolean, boolean]

Processes the StreamEvent.

Parameters

  • processorAlias string?
  • alias for the calling processor, for identification purposes (lhs, rhs).

  • Return Type

    ([boolean, boolean])
  • a tuple indicating, whether the event is promoted and whether to continue to the next processor.

setStateMachine

Set the StateMachine to the procesor and it's descendants.

Parameters

validate

Validates the processor and its configs.

promote

Promotes the StreamEvent to the previous processor.

Parameters

  • processorAlias string?
  • alias for the calling processor, for identification purposes (lhs, rhs).

evict

Evicts the StreamEvent from current state branch.

Parameters

  • processorAlias string?
  • alias for the calling processor, for identification purposes (lhs, rhs).

remove

Removes a given StreamEvent from the StateMachine.

Parameters

emit

Emits given StreamEvent as a fulfilled event.

Parameters

flushAndGetFulfilledEvents

()

returns StreamEvent?[]

Returns fulfilled state events and flush returned states from the state machine.

  • Return Type

    (StreamEvent?[])
  • an array of StreamEvents.

setPreviousProcessor

Sets a link to the previous AbstractOperatorProcessor.

Parameters

setProcessor

Sets a link to the descendant AbstractOperatorProcessor.

Parameters

getAlias

()

returns string

Returns the alias of the current processor.

  • Return Type

    (string)
  • alias of the processor.