Tag: get event store

集成testinggeteventstore使用rxjs有竞争条件

对不起，这个有点乱。 我的项目在nodejs中。 我在摩卡testing。 在这里我打开一个连接到geteventstore并订阅一个stream。 这基本上开始发射事件。 我把这个事件订阅包装在一个rxjs observable中，然后把它写到控制台。 有一半的时间我有一半的时间，我没有得到一个事件stream。 我感觉到eventloop开始聆听，没有听到任何东西，并在geteventstore可以开始使用事件爆炸之前closures。 我有点不知所措 我可以告诉geteventstore发送数据cuz一半的时间，我得到它。 我的理解是，只要有人订阅了一个事件，例如有一个事件侦听器，循环就会保持打开状态。 所以也许问题是与rxjs？ 我不知道，任何帮助将不胜感激。 – – 编辑 我不知道这是否会有所帮助，但testing看起来像这样。 context('when calling subscription', ()=> { it('should stay open', function () { mut = bootstrap.getInstanceOf('gesConnection'); var rx = bootstrap.getInstanceOf('rx'); var subscription = mut.subscribeToAllFrom(); rx.Observable.fromEvent(subscription, 'event').forEach(x=> console.log(x)); subscription.on('event', function (payload) { console.log('event received by dispatcher'); console.log('event processed by dispatcher'); […]