我创建了多个Observable，订阅了它们，并希望在返回数据时在同一线程上获得通知(调用DoSomething())。我试过BlockingCollection<>，但徒劳无功。
浏览 3提问于2020-02-07得票数 1
2回答
我正在设计一个静态消息总线，它允许订阅和发布任意类型的消息。为了避免要求观察者显式取消订阅，我希望跟踪指向委托的WeakReference对象，而不是跟踪委托本身。我的问题是:与Paul的代码相反，我的观察者在一个线程上订阅消息，但消息可能在另一个线程上发布。在这种情况下，我观察到，当我需要通知观察者时，我的WeakReference.Target值为null，表
浏览 0提问于2012-01-11得票数 1
当我订阅一个主题的多个观察者时，是否保证按照订阅的顺序调用这些观察者？Observer 3".Dump());
// Observer 2我明白，在多线程场景中，事情会变得相当棘手，所以我想特别要求使用单线程的情况。主题被订阅并在同一<
浏览 1提问于2013-08-20得票数 0
回答已采纳
所以，基本上，rxjs是新的，想知道，
我是否需要从Observable.of(数据)或更新的rxjs版本中取消订阅(数据)？
浏览 2提问于2019-04-28得票数 6
在谈到异步的中，有一句话是“可观察的请求是异步订阅的，并在执行HTTP请求的同一线程上观察到的”，我想澄清一下。那么，在这种情况下，哪个线程将实际执行Http请求:假设主线程调用可观察路径(@getUserPhoto(“id”) int )？是订阅请求的主线程还是执行http请求的线程？
浏览 0提问于2014-09-11得票数 1
我目前让回调在线程池中执行。我为每个回调启动一个后台线程。线程非常短暂，涉及的工作包括获取数据和通知观察者。一旦通知观察者，后台线程就会终止。当我的策略订阅了超过1000个活跃交易的符号时，我得到了OutOfMemory异常。
我如何改进这个设计？我在考虑在开始时启动两个线程，一个用于引用，另一个用于执行，并在各自的线程上创建每个对象。然后只需要
浏览 1提问于2011-05-17得票数 1
9回答
Subject在自己的线程中运行(在订阅的观察者上调用Notify() )，互斥对象保护它的内部观察者列表。
我可以在取消订阅调用中标记一个删除的观察者，并将其从主题线程中删除。发生这种情况的最明显的方式--客户端调用
浏览 9提问于2009-02-10得票数 11
回答已采纳
1回答
现在，我认为这是一个非常糟糕的主意，因为订阅对象上事件的代码可能根本不被设计为多线程，而该对象的实现(应该是一个黑匣子，不是吗？)，如果多线程在幕后(在我的例子中)会导致订阅者代码在多个线程上执行，会导致各种奇怪的问题。
因此，我的问题是，是否有可能将事件推回原来订阅它的线程，从而避免订阅者级别上的任何意外并发？或者更抽象地说，我是否可以在某个时间点记录当前<em
浏览 7提问于2011-04-03得票数 1
回答已采纳
我使用名为'globalVariables‘的服务在应用程序模块和组件之间共享数据，在该服务中有一个名为'var’的变量，有两个组件A、B正在使用该服务和'var‘变量。一旦组件B更改了特定变量的值属于服务x，我如何重新加载组件A的html。 <div> <app-header> </app-header> <app-side-nav-bar
浏览 0提问于2018-04-23得票数 0
为什么subscribe从不在这里打印任何东西？只是出于好奇。无论如何，这是一种糟糕的做法:我通常会使用observeOn。然而，我不明白为什么subscribe从来没有到达.val countDownLatch = CountDownLatch(1)
.map { it + 1 } .subscribe {
println(Th
浏览 2提问于2020-08-09得票数 1
回答已采纳
在可观察值更改之后(例如，可观察数组中的许多项)，视图的渲染是否同步发生？
我关心的是，在视图渲染(可能还包括所有相关计算的处理)结束之前，是否可以执行任何其他JavaScript代码。因为JavaScript是单线程的，所以如果对更改的值的处理是同步的，那么我的理解是不能执行其他JavaScript代码，也不能处理用户操作(例如，输入值的更改)。
浏览 2提问于2014-01-31得票数 2
1回答
我正在学习在winforms中使用Rx。当我使用此代码时，请告诉我如何更新我的progressBar。 l => {
XtraMessageBox.Show(this, "Welcome " + DefaultManager.Principal.Identity.Name, "Loged in successfully", MessageBoxButtons.OK, Messag
浏览 0提问于2012-03-04得票数 0
我非常理解订阅的概念( subscribeOn下面的任何代码都将在该特定线程中执行)，并在rxandroid/rxjava中观察(与subscribeOn相同)。我想要做的是在后台线程中执行长io操作，然后在操作完成时通知主线程。为此，我正在考虑在Schedulers.io()中订阅一个subscribe，然后在AndroidSchedulers.mainThread()中观察一个subscribe，如下所示：
Observ
浏览 5提问于2016-08-25得票数 0
假设我有一个observableA，它从网络获取数据并发出数据，如果我每次订阅这个可观察对象，它都试图从网络请求大量数据。我想创建BehaviorSubject并将其连接到observableA，这样任何其他线程/对象都将订阅BehaviorSubject，以便获得最新发出的数据。
到目前为止，我还不能把它写成代码。我不能创建空的BehaviorSubject并在observableA内部调用，因为它们彼此不相关。我不能订阅
浏览 3提问于2014-06-06得票数 10
5回答
System.out.println("3: " + Thread.currentThread().getId());例如，输出将为：2: 100我希望订阅者在id为50的线程上运行。
浏览 2提问于2015-11-06得票数 5
1回答
房间流动缓存
、、、
Schedulers.io()) .subscribe { accounts = it }我如何使一个可观察的，将发出的实际内容，每次有人订阅，并将通知每一个订户时，数据变化？
浏览 4提问于2017-10-29得票数 2
回答已采纳
1回答
我正在浏览观察者设计模式，并有一些问题，我没有一个明确的答案，所以会感谢围绕他们的任何想法/想法。这特别涉及多线程场景中的异步观测器回调：
我认为我们可以先讨论这个问题，我相信我们会有更
浏览 1提问于2013-12-30得票数 1
我的应用程序在一个线程中处理一些图像，同时它显示一个带有进度条的对话框。但是线程不会改变这个新对话框的进度条。
浏览 12提问于2019-04-30得票数 1
3回答
所以我在玩RX (真的很酷)，我一直在转换我的api，这个api访问Android中的sqlite数据库，以返回可观测值。这花了我一两个小时，但我最终找到了，它帮助我轻松地走出了困境： Observable<Integer> two = getNumberedObservable(2);
Observable<In
浏览 2提问于2014-01-18得票数 15
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
