711
*/
712
export function transform<Original, Transformed>(stream: ReadableStreamEvents<Original>, transformer: ITransformer<Original, Transformed>, reducer: IReducer<Transformed>): ReadableStream<Transformed> {
713
>
const target = newWriteableStream<Transformed>(reducer);
stream.ts
714
>
715
>
listenStream(stream, {
716
>
onData: data => target.write(transformer.data(data)),
717
>
onError: error => target.error(transformer.error ? transformer.error(error) : error),
718
>
onEnd: () => target.end()
719
>
});
720
>
721
>
return target;
722
>
}
723
724
/**