Package com.framed.arn

package com.framed.arn

Class	Description
ARN	Acyclic Deterministic Reactor Network validator.
FiringRule	Structured representation of a parsed channel condition.
Reactor	A reactive multi-input Service that evaluates a set of firing rules on incoming messages, constructs exactly one consistent snapshot per evaluation cycle, and triggers a user-defined Reactor.reactionFunction(Map) once whenever at least one rule is satisfied.
Reactor.Snapshot	An immutable evaluation snapshot handed to Reactor.reactionFunction(Map).
RuleType	Enumerates the types of channel conditions supported: RuleType.ANY: at least one new message RuleType.AT_LEAST: at least n new messages RuleType.REQUIRE_VALUE: at least one new message and latest value equals value
RuleUtils	Runtime helpers shared by Reactor and its concrete implementations: extracting a logical timestamp from an incoming message and publishing a result envelope to a reactor's output channels.