Support stream/firehose and stream/sample