我对Rx如何处理Subscription#unsubscribe方法很感兴趣。subscription.unsubscribe();
它是否提供了取消订阅会在整个流中停止发出事件的保证？
浏览 0提问于2016-07-02得票数 0
在我们的颤振应用程序中，内存泄漏和流没有关闭。我们将源代码追溯到代码，如：RxDart .combineLatest()的结果是一个单一订阅流。添加.asBroadcastStream()使流可以方便地用于我们的各种颤振显示器。但是，当这些显示关闭时，正在组合的流仍然处于活动状态
浏览 2提问于2020-02-29得票数 1
回答已采纳
Observable在类首次加载到内存中时启动，然后定期执行我的代码。因为它是一个单一的可观察对象，所以从我的测试看，它肯定是一个假设，即代码永远不会第二次启动并并行处理，以防它运行的时间超过间隔。}).subscribeOn(Schedulers.newThread()).observeOn(Schedulers.newThread())但这也有一个缺点并不是那么糟糕，但真正的问题<em
浏览 1提问于2014-12-11得票数 0
1回答
这更像是我的一个通用的设计查询。我通过维护订阅者列表实现了发布/订阅模式。当要发布的事件发生时，我循环遍历订阅者，并依次将事件推送到每个订阅者。我的问题是，由于发布，在软件深度的某个地方，另一个组件或事件被描述<
浏览 1提问于2011-05-26得票数 1
回答已采纳
突然间，如果我从一个StreamSubscription获得了一个Stream，那么当我完成的时候，有什么适当的礼仪来清理资源呢？
一个Stream实现，它只返回一个不断增加偶数<em
浏览 2提问于2021-12-30得票数 1
我想取消一个流，发现一个Stream不能被取消，但是StreamSubsciption可以被取消。Stream对象有一个listen()方法
来自
对流中事件的订阅。当您使用Stream.listen侦听流</em
浏览 5提问于2021-12-11得票数 1
回答已采纳
如果我有一个包含可观察的服务并且我有以下代码..。this.collapse.process("helpArea", true); // I would like to detach now是否可以在不取消原始订阅的情况下分离如果我调用unsubscribe，那么当我调用this.collapse.newChild.next("thing")时，它会抛出一个错误Error:
浏览 2提问于2017-01-18得票数 4
回答已采纳
任何时候调用web服务时，都会更新数据，并通过发布的事件通知订阅者。
我在RxJava和AsyncSubject中设置了一些类似的东西。观察者从主题中得到一个事件，但是他们得到一个onComplete事件并取消订阅。这在UI第一次加载时起作用，但是当需要刷新数据时，不需要通知订阅者。PublishSubject只</em
浏览 4提问于2014-07-23得票数 12
回答已采纳
1回答
在我们的客户端应用程序中，我们通过SignalR.Client发送和接收实时事件。从服务器订阅事件是通过SignalR完成的。然而，我们现在有几个例子，相同的可观测的共享多个观察者。处理可观察到的每个内部订阅进行得很好，但是在释放最后一个观察者之后，我想取消订阅，不接收服务器上的</e
浏览 3提问于2013-04-17得票数 1
回答已采纳
最初有一个公共空间，用户订阅或加入公共空间，然后每个订户都可以选择“私密”。一旦任何订阅者点击“让它成为私有”选项，那么所有订阅者将从那里的浏览器连接到dis，但与房间创建者或发布者连接。
但在其他订阅者上，他们将无法显示单击“使其成为私有选项”的用户。因为该用户从其他订阅者屏幕连接到dis，并且只显示在发布<
浏览 5提问于2016-01-09得票数 0
回答已采纳
2回答
LiveData看起来非常有用，因为它只在视图处于活动状态时通知视图。它还会在订阅后将最后一个值存储并返回给新订阅者。我知道和，但
浏览 0提问于2018-06-17得票数 0
在我的代码库中有几种情况，我订阅的流只会发出一个结果，因此使用rx.Single而不是rx.Observable是有意义的。单曲的如下所示：
单个将只调用这些方法中的一个，并且只调用它一次。在调用任一方法时，单个方法终止并结束对它的订阅。使用传统的
浏览 6提问于2016-06-12得票数 9
回答已采纳
2回答
我正在尝试解决以下问题: a)订阅者在一段时间内从IObservable接收事件。然后它取消订阅，做一些事情，然后再次订阅。在这里，它应该从执行取消订阅的同一点开始接收事件。b)这样的行为对于多订户模型是可取的。例如，当一个人取消订阅时，其他人应该继续接收事件。
RX方面有什
浏览 2提问于2011-10-10得票数 0
回答已采纳
2回答
我有一个INotifyPropertyChanged对象Foo。我使用Rx的FromEvent方法将Foo转换为可观察的事件流：var eventStream = Observable.FromEvent<PropertyChangedEventArgs>(myFoo, "PropertyChanged");
现在，我要侦听特定属性的更改，如果是.Prog
浏览 0提问于2010-08-10得票数 7
回答已采纳
我想可以继续订阅一个可观察对象，然后忘记取消订阅。我怀疑这是在我的应用程序中发生的。observable有没有一个属性可以让我知道挂在它上面的订阅者的数量？
浏览 2提问于2016-07-28得票数 9
2回答
一个简单的问题。假设我在下面的例子中实现了一个类。EventHandler(OnEventFired); {在程序中的某个地方，我有一个方法，看起来像这样：{
Subscriber subscriber = new Subscriber
浏览 6提问于2011-07-13得票数 8
回答已采纳
4回答
如何完成RxJS中的可观测性？
、、、、
假设我们有一个可观测的 .fromEvent(document.getElementById('emitter'), 'click');
如何使它完成(什么将为所有订阅的观察者触发onComplete事件)？
浏览 6提问于2015-12-04得票数 27
回答已采纳
我的要求是让订阅者暂停处理消息，这取决于web服务是否启动。因此，当web服务关闭时，消息应该继续从发布者进入订阅者队列，并不断堆积，直到web服务再次启动。(这些消息不应进入错误队列，而应留在订阅者队列中。)
我尝试使用取消订阅，但发布者停止发送消息，因为取消订阅似乎清除了RavenDB上<
浏览 0提问于2014-07-25得票数 0
还是应该由RxJS来处理活跃订阅？不管是谁，为什么它不自动取消订阅所有的活动订阅，或者至少提供一个在组件销毁时或在某个最终事件时自动取消订阅或取消订阅所有订阅者的标志？
浏览 3提问于2021-04-12得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
