Implement streaming protocol (mw_feed_...)