Stream documents from a mongo cursor with a constant level of concurrency