[WIP] [RFR] Implement streaming endpoint

Hm, actually, I've just copy-pasted that part and assumed ConsumerMixin needs this stuff. I'll check.