Откажитесь от чанка в потоке NodeJS Transform и прочитайте следующий

Question

Как мне отбросить кусок в потоке преобразования NodeJS и прочитать следующий из предыдущего потока?

stream.on('data',function(data){}).pipe(rulesCheck).pipe(step1).pipe(step2).pipe(step3).pipe(insertDataIntoDB);

Я бы хотел отказаться от чанка, если он не соответствует определенным критериям в потоке ruleCheck.

Answer 1

Напишите дуплексный поток и вставьте его посередине.

Чтобы упростить это, посмотрите на библиотеки как event-stream, которые могут упростить реализацию.