Я пишу загрузчик с помощью node.js и модуля запроса. Используя синтаксис потока I 'я делаю

var r = request(url).pipe(fs.createWriteStream(targetPath));
r.on('error', function(err) { console.log(err); });
r.on('finish', cb);

чтобы загрузить файл, сохраните его и перезвоните. Однако почти в 50% случаев файл либо пустой, либо не создается вообще. нетerror событие испускается. Кажется, чтоfinish событие инициируется, хотя файл не былт (полностью) написано еще.

Контекст: все это завернуто вasync.each звонки.

Есть какие-нибудь подсказки? Спасибо!