передача данных из 1 потока в 2 разных потока в зависимости от данных

Question

У меня есть 1 поток с поступающими данными, который имеет префикс 2 разных префиксов. скажем, 1 и 0. Я хочу, чтобы все данные с префиксом 1 передавались по конвейеру только в поток А, а 0 - в поток Б.

Я подумал только об использовании 2 преобразований, которые пропускают данные, только если они имеют правильный префикс. Мне было просто интересно, есть ли более элегантный способ сделать это.

//an idea

//transformA is a transform that only pushes data that is prefixed with 1
//transformB is a transformt hat only pushes data that is prefixed with 2
incomingStream.pipe(transformA).pipe(destinationA)
incomingStream.pipe(transformB).pipe(destinationB)

Answer 1

Используйте for-await и if, может быть?

for await (const chunk of incomingStream) {
    if(chunk.startsWith("1")) {
        destinationA.write(transformA(chunk));
        continue;
    }

    if(chunk.startsWith("2")) {
        destinationB.write(transformB(chunk));
        continue;
    }

    destinationElse.write(chunk);
}