Firehose streaming API implemented