У меня есть читаемый поток из файла csv, обработайте его с помощью csv2 и преобразуйте каждую строку в документ JS (с mississippi.through), чтобы отправить его в PouchDB, поэтому
rs.pipe (csv2) .pipe.(row2doc) .pipe (pouchPushStream)
, где pouchPushStream является stream.Writable и имеет два метода, как обычно, _write () и _writev ().
Цепочка работает как символпоследний толкающий поток.Тогда метод _write () работает нормально, но как я могу запустить _writev () после _write (), чтобы отправить в Pouch 1000 документов за раз?
Возможно ли это с помощью метода .pipe?