Composition of pattern-driven reactions in real-time dataflow programming

A method comprising:

• interconnecting a plurality of agents and sensors;
• converting streams of input data from the sensors into streams of output data via a series of interconnected transductions;
• storing in a first memory location a sequence of tokens to be processed and a time stamp associated with each token that indicates a time associated with the token
• identifying patterns in the sequence of tokens that attempt to match one or more predetermined input patterns, and upon identifying a matched predetermined input pattern, generating an outgoing event output;
• determining, by a triggering expression, when to evaluate a filtering expression;
• determining when a transduction will produce outputs based on the filtering expression;
• and
• producing the outputs of the transduction.

One or more non-transitory computer readable media containing program instructions that, when executed by one or more processors, cause the one or more processors to perform operations comprising:

• interconnecting a plurality of agents and sensors;
• converting streams of input data from the sensors into streams of output data via a series of interconnected transductions;
• storing in a first memory location a sequence of tokens to be processed and a time stamp associated with each token that indicates a time associated with the token identifying patterns in the sequence of tokens that match one or more predetermined input patterns, and upon identifying a matched predetermined input pattern, generating an outgoing event output;
• determining, by a triggering expression, when to evaluate a filtering expression;
• \
• determining when a transduction will produce outputs based on the filtering expression;
• and
• producing the outputs of the transduction.