NodeJS Streams Ожидание потоковой передачи всех данных

Мой код передает данные из коллекции mongo и вставляет их в другую БД после выполнения с ней некоторого количества операций.

Кажется, я не могу найти способ дождаться, пока все данные будут обработаны, прежде чем закрывать соединения с БД. Обработка данных завершается через несколько секунд после «закрытия» потока. Хочу дождаться ВСЕХ данных операции, которые необходимо завершить перед закрытием соединений с БД. Как мне это сделать?

PS: Я вижу, что все данные оперированы. Это хорошо работает. Но я хочу закрыть соединения с БД. Мне нужно дождаться завершения всех операций, прежде чем делать это!

var count = 0; // Counter for number of mongo docs that has been inserted in new_db
mongo_db.collection(config.collection, function (err, coll) {

    coll.find(config.mongo_query).count(function (e, coll_docs_count) {

        var stream = coll.find(config.mongo_query).stream();
        stream.on('close', function () {

            if (count === coll_docs_count) {
                // This NEVER executes since the data is finished
                //being operated and inserted in the NEW DB a few seconds after
                //this moment.
                mongo_client.close();
                cb_bucket.disconnect();
            }

        });

        stream.on('data', function (doc) {
            ... // Do some operations on it
            new_db.insert(doc, function (blah blah) {
                count++;
            })
        })
    })
})