General Streaming API implementation