如何使用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);
我遵循了RxJS文档的示例(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');
它不工作,因为您正在发出command
,这可能是您的事件的主体,而不是事件名称。fromEvent
将只监听单个事件名称。
你应该做eventEmitter.emit('cmdStart', command)