Robust, forward-thinking, and extensible streams for the web