Historical prototype.
Now it is better implemented using streams instead of just using the promises provided by elasticsear to control flow.
Added speedometer to get speed of the streams.
Fixed bug: BulkQueryRunnerStream didn't emit data when it was called synchronously.