If I have a Node js stream, say for example from something like process.stdin or from fs.createReadStream, how can I convert this to be an RxJs Observable stream using RxJs5? I see that RxJs-Node has a fromReadableStream method, but that looks like it hasn’t been updated in close to a year. Answer For anyone looking for this, following Mark’s recommendation,