Example – stream processor flow control