如何將'process.on'更改爲基於RxJS風格的事件？

Question

如何使用Rx監聽NodeJS事件？

我在我的JakeJS文件中有以下代碼。

process.on("cmdStart",() => { 
    console.log("> " + command) 
}); 

，我想這樣做在RxJS風格，但我真的不知道什麼是做到這一點的最好辦法。

我已經閱讀了文檔，並嘗試了一些他們在github上提供的示例，但我不太確定，似乎並不奏效，這是我試過的。

const eventEmitter: any = new EventEmitter(); 

const cmdStart = Rx.Observable.fromEvent(eventEmitter, "cmdStart"); 

const subscription = cmdStart.subscribe(function (command) { 
    console.log("> " + command) 
}); 

eventEmitter.emit(command); 

Answer 1

我已經按照（https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/fromevent.md）

var Rx = require('rx'); 
var EventEmitter = require('events').EventEmitter; 

var eventEmitter = new EventEmitter(); 

var source = Rx.Observable.fromEvent(eventEmitter, "cmdStart"); 
source.subscribe(function (x) { console.log("> " + x) }); 
eventEmitter.emit('cmdStart', 'testdata'); 

Answer 2

它不工作RxJS文檔的例子，因爲你都散發command，這大概是你的活動的主體，而不是事件名稱。 fromEvent只會偵聽該單個事件名稱。你應該做eventEmitter.emit('cmdStart', command)。