如何在rxjs中使用节点的变换流？

我已经玩rxjs了一段时间了,我喜欢如何使用它的逻辑运算符而不是命令式编程.但是,我也喜欢节点的流,它也是高度可组合的,所以我明显的反应就是使用它们但我还没有看到它被提到很多(实际上,我根本没有)除了在rxjs的书中绑定它.

所以,我的问题是,如何利用RxJS上npm中的所有变换流？或者,它甚至可能吗？
例:-

var fs = require('fs');
var csv = require('csv-parse')({delimiter:';'});
var src = fs.createReadStream('./myFile.csv');
src.pipe(csv).pipe(process.stdout);

基本上,我想这样做: -

var fs = require('fs');
var csv = require('csv-parse')({delimiter:';'});
var rx= require('rx-node');
var src = fs.createReadStream('./myFile.csv');

var obj = rx.fromReadableStream(src);
obj.pipe(csb).map(x=>console.log(x));

我被告知highland过去使用但我在rxjs这里严格寻找解决方案.