Chaining data types between streams

[piglovesyou]

What's expected

The argument types should be inferred by the previous stream.

pipeline(
    Readable.from([2, 3, 4]),
    pipe(n => {
      n as number // Typed as number
      return `${n} is coming!`
    }),
    pipe(message => {
      message as string // Typed as string
      return { message }
    }),
    pipe(obj => {
      obj as { message: string} // Typed as { message: string}
    }),
    (err) => {}
)

Problem

Node's ReadableStream/WritableStream/ReadWriteStream are not typed. DefinitelyTyped/DefinitelyTyped#45196 and DefinitelyTyped/DefinitelyTyped#45222 tackled it, but it seems difficult to modify the base types that many other modules depend on.

Possible solution

It could be controversial, but how about providing additional types by Declaration Merging only for pipeline-pipe users? We have to give up third-party transformers lose types, but we may be able to type our pipe() and the other utilities.