Streaming interface for nsq