Запись с учётом backpressure

Напиши async pump(source, sink). source: асинхронный итерируемый источник чанков. sink: объект в стиле Writable:

• write(chunk) возвращает false, если внутренний буфер переполнен (писать дальше нельзя до события drain);
• once(event, fn): подписка на 'drain' или 'error';
• end(): завершить запись.

pump пишет все чанки, при false ждёт drain и только потом читает следующий чанк из источника; в конце вызывает end() и возвращает число записанных чанков. Если sink сообщил error, пока ждём drain, промис отклоняется этой ошибкой.