相关疑难解决方法(0)

如何在RxJS中完成Observable

假设我们有一个Observable:

var observable = Rx.Observable
    .fromEvent(document.getElementById('emitter'), 'click');
Run Code Online (Sandbox Code Playgroud)

如何使其完成(什么将触发所有订阅的观察者的onComplete事件)?

javascript stream observable rxjs reactivex

10
推荐指数
2
解决办法
3万
查看次数

RxJS订阅者取消订阅与完成

我是通过RxJS文档阅读,并希望确保我理解之间的差异Subscriber.unsubscribe()Subscriber.complete().

假设我有两个订阅者,即subscriber1和subscriber2的observable.如果subscriber1呼叫取消订阅他们的订阅,它将不再接收来自observable的通知,但subscriber2将继续接收它们.

文档.complete():

Observer回调从Observable接收类型为complete的无值通知.通知Observer Observable已完成发送基于推送的通知.

这是否意味着在上面的相同场景中,subscriber1可以调用complete并且它将结束observable并停止subscriber1和subscriber2的流?

javascript rxjs

9
推荐指数
2
解决办法
5741
查看次数

标签 统计

javascript ×2

rxjs ×2

observable ×1

reactivex ×1

stream ×1