Implement the Streaming API (Not completed)