rx-node writeToStream 没有将输出发送到 process.stdout

Question

我一直在使用 RX (rx-node) 的节点扩展，但在使用特定函数 writeToStream 时遇到问题。

以下示例不会向控制台发出任何值 (process.stdout)：

var Rx = require('rx');
var RxNode = require('rx-node');
var source = Rx.Observable.range(0, 5);
var subscription = RxNode.writeToStream(source, process.stdout, 'utf8');

我已经尝试使用一种替代方法，使用简单的订阅，效果很好（我将 "next" 的输出直接写入控制台），但这是让 writeToStream 工作的解决方法。

我需要做什么才能使 writeToStream 正常工作，有什么想法吗？感谢任何帮助。

Answer 1

此问题是rx-node 1.0版本的bug。直接在最新的versions. However these fixes are not yet on npm, the best fix right now is to download the master source中修复了（只有一个文件）

更新 1 从版本 1.0.1

开始，修复程序现已在 npm 上运行

rx-node writeToStream 没有将输出发送到 process.stdout

rx-node writeToStream not emitting output to process.stdout

rxjs