System and method for using stream objects to perform stream processing in a text-based computing environment

A device comprising:

• a memory to store instructions;
• and
• one or more processors to execute the instructions to:
• generate a definition of a data stream processing class,
• the definition of the data stream processing class identifying a plurality of operations,
• the plurality of operations including:
• an output operation that produces a value for an instance of the data stream processing class, and
• an update operation that updates a state of the instance of the data stream processing class,
• the output operation and the update operation being called using an Application Programming Interface (API),
• the API being defined by the definition of the data stream processing class,
• instantiate the data stream processing class to implement the API, and
• process, using the instance of the data stream processing class and via the API, a data stream in a text-based computing environment or a graphical computing environment,
• when processing the data stream, the one or more processors are to:
• perform one or more of the output operation or the update operation on the data stream.

A non-transitory computer-readable medium storing instructions, the instructions comprising:

• a plurality of instructions which, when executed by one or more processors, cause the one or more processors to:
• generate a definition of a data stream processing class,
• the definition of the data stream processing class identifying a plurality of operations,
• the plurality of operations including:
• a first operation that produces a value for an instance of the data stream processing class, and
• a second operation that updates a state of the instance of the data stream processing class,
• the first operation and the second operation being called using an Application Programming Interface (API),
• the API being defined by the definition of the data stream processing class,
• instantiate the data stream processing class to implement the API, and
• process, using the instance of the data stream processing class and via the API, a data stream in a text-based computing environment or a graphical computing environment,
• one or more instructions, of the plurality of instructions, to process the data stream including:
• one or more instructions to perform one or more of the first operation or the second operation on the data stream.