When working with the streaming api, you now call open on a flow-id. This will give you back a FlowConnection which has two methods (currently) read and close. When you call read it will take the next line off of the stream, parse it as json, and then hand it back to the user. This will allow users to handle each flow as its own resource. When the api is requested to join a new flow you can spawn a new resource for reading messages from that flow without dropping any messages on the floor.