Implement from Node.js Streams

[mattpodwysocki]

IxJS version:

Code to reproduce:

Expected behavior:

Actual behavior:

Additional information:

IxJS, since it's specialty is in I/O problems, that we need explicit conversions to and from Node.js streams. This will intrinsically support backpressure as you do not pull more than you need. We already have AsyncSink which is a Node.js stream already, but we would like a more explicit approach.

export function fromReadableStream(
  stream: Readable, 
  size?: number)
: AsyncIterable<string | Buffer>;