Pipe events to numbers and maintain a running count using the scan operator

In this lesson, we will use the simple data sources we created earlier, to create a more specialized stream that gives us the current count of tasks that are in progress.