use along with RxNode

[ZigGreen]

The problem is:
when I try to pass a csv stream to NodeRx.fromStream it has no effect.

var fs = require('fs');
var csv = require('fast-csv');
var stream = fs.createReadStream("file.csv");

var RxNode = require('rx-node');

var subscription = RxNode.fromStream(stream.pipe(csv()))
    .subscribe(function (x) {
        console.log(x); 
});

I've took a brief look at the fromStream source code and it seems to be that addListener('data', ...) has no effect on stream.pipe(csv()) stream. I wonder why.

If I change addListener('data', ...) to on('data', ...) in the NodeRx sources, It starts working as expected.