C++ Reactive Programming

The Streamulus Library – a look into expression processing

We will take a look at how Streamulus processes expressions using a simple Stream expression:

InputStream<int>::type x = NewInputStream<int>("X"); 
Engine.Subscribe( -(x+1)); 

The - (x+1) Stream expression will produce the following graph. The term  strop stands for Stream operators and each of the nodes is organized as a strop:

Once the node has been labeled correctly, a topological sort on the graph will be done to determine the execution order. The following diagram shows a topological sort (you can have multiple topological orders):

The Streamulus engine walks through the graph ...