[WIP] [RFR] Implement streaming endpoint

NVM, it looks like you put a tuple into the queue. Nit: Explicit paranthesis around the tuple is preferred.