yarn add @alfalab/node-utils
import { createTransformDataStream } from '@alfalab/node-utils';
-
createTransformDataStream
— Форматирует стрим с измененным объектом на основе конфига.pipeline[Readable.from(JSON.stringify({ phones: ['+123','+234'], meta: 'info' })), createTransformDataStream({ replace: { phones[*]: (value)=> value.slice(1) })], filter: ['meta'] })] -> Stream<{ phones: ['123','234'] }>