rxjs5

2热度

2回答

例如，假设我想进行一些API调用。我正在处理的api很容易出现竞争状况，所以如果我在同一时间更新服务器上的同一条数据时发出3个api调用，它可能会丢失一些数据。因此，我想排队我的请求，然后在发出下一个请求之前开启等待响应返回。基本上我需要类似concatMap的东西，但concatMap的问题是它同时触发所有的请求。我需要concatMap在发射下一个请求之前等待。我正在使用rxjs 5. 这

0热度

1回答

如何确保Angular服务构造函数中的异步初始化完成？

专家请告诉我如何在调用类中的其他函数时确保服务构造函数中的异步初始化完成？ constructor() { var sock = new SockJS(this._chatUrl); this.stompClient = Stomp.over(sock); this.stompClient.connect({}, function() { });

3热度

1回答

史诗不会对来自另一史诗的行动作出反应

我有一个redux-observables的问题。在我的情况下，史诗般的等待结束另一部史诗。第二部史诗可以从缓存发出请求或返回数据。当第二个请求全部按预期工作时，但当它返回缓存时，第一个不会继续。 const { Observable } = Rx; const FETCH_USER = 'FETCH_USER'; const FETCH_USER_FULFILLED = 'FETCH_U

0热度

1回答

执行逻辑时RxJS 5的refcount（）从源

连接到或取消订阅按照RxJS 5手册关于Multicasting ...我们可以使用ConnectableObservable的引用计数（）方法（参考计数），它返回部一个可以跟踪它拥有多少用户的Observable。当用户数量从0增加到1时，它会为我们调用connect（），这会启动共享执行。只有订户数量从1减少到0时，它才会完全取消订阅，停止进一步执行。我想了解是否有可能钩到这些事件，并执行一

3热度

2回答

组合/合并可观察对象

假设我正在开发一个聊天应用程序。我观察到的threads$发出每ň秒线程的阵列，观察到offline$当一个线程下线成为了通知，可观察online$当一个线程成为网上通知： enum ConnectionStatus { Offline = 0, Online } interface Thread { id: string; status: ConnectionStatus

3热度

1回答

有没有办法知道rxjs websocket是否打开

我在一个角度4的项目中使用RxJS。我试图启动一个WebSocket，特别是要知道什么时候这个打开。我目前使用RxJS（v5）的WebSocket。 https://github.com/ReactiveX/rxjs/blob/master/src/observable/dom/WebSocketSubject.ts 我注意到WebSocketSubjectConfig中有一个openObse

1热度

2回答

如何使用RxJS从arrayBuffer拆分数据框？

我使用websocket从硬件接收数据帧。数据帧的定义如下： 0xbb(head) ---data--- 0xee(tail) 所接收的数据是存储在Uint8Array，可以存在多个帧： var buffer = new Uint8Array([0xbb,0,0,0,0xee,0xbb,1,1,1,0xee,0xbb,3,3,3,0xee]); ，我可以在阵列转换为可观察到的： var ob

0热度

1回答

在Rx.js中，我怎样才能区分哪个流触发combineLatest方法？

我正在写我自己的版本who to follow?。点击refreshButton将获取建议列表并刷新<Suggestion-List />，并且closeButton将从建议列表中重新提取数据并刷新<Suggestion-List-Item />。我想让closeClick $和suggestions $结合在一起来驾驶用户。这里演示代码： var refreshClick$ = Rx.Obs

0热度

2回答

Observable.next（）休息循环

这段代码解析三元组（不是那么重要），并且应该一次返回一个停车位。问题在于调用observer.next（）会中断循环，因为它只运行一次。 console.log也不会被调用。我可能错过了一些东西，但有可能observer.next（）打破循环？有没有错误，或者它是一个功能，或者我只是明显错误？ return Observable.create(observer => { this.fet

1热度

1回答

RxJS：链式观察量不使用相同的根可观察值

我正在尝试学习RxJS，并试图构建我认为是一个简单而直接的示例。创建一个间隔生成的随机数的可观察值，然后根据该可观察值使用另外两个可观察值来跟踪已经看到的最低值和最高值。 rStStream似乎表现得像预期的一样，minStream和maxStream都显示正确跟踪。我遇到的问题是，当执行它时，似乎rngStream，minStream和maxStream在每个时间间隔上都有不同的随机数。我试图了