как излучать несколько объектов из NodeJS фаза преобразования потока - PullRequest
0 голосов
/ 13 февраля 2020

Я получаю курсор MongoDB с пользователями, которых я хочу преобразовать в CSV.

mongodb.find().stream().pipe(csv.transform(user => {
   if (user.is_active) {
       // send object {active: true, user: user.id}
   }
   // send object {user: user.id, random_variable: user.random}
   return {user: user.id, random_variable: user.random}
})).pipe(csv.strigify())

Моя проблема в том, что я хочу, чтобы некоторые пользователи испускали 2 объекта / создавали 2 строки в CSV.

Как это сделать?

...