Updated to give a sense of how long each item is taking to process through the stream (very helpful for debugging)