1回答
我将它与Subscriber配对以订阅间隔。当某个模型的数据耗尽时，我会取消订阅并等待新的到来。当他们的数据再次被填充时，我尝试再次订阅，但它不起作用。所以我必须用Observer替换它。我是个新手，我不知道怎么做。我试着看了一些例子，他们只是让我更困惑。 }我是这样订阅
浏览 0提问于2018-09-02得票数 1
回答已采纳
2回答
具有反应性扩展的双向通信
、、、
此源是与远程服务器的套接字连接，该服务器提供有关当前位置天气的信息。
远程服务器还可以向我发送有关其他相关主题的事件，如交通、极端天气警告等。如果我发出命令来表示这个愿望。我如何在不创建可观察到的和观察者之间的耦合的情况下用反应性扩展来建模呢？其思想是，当我订阅ExtremeWeatherWarnings (观察者)到我的WeatherServerConnection (可观察的)时，第一种方式是向第二种发出一些命令，所以它允许订阅。我尝试在观
浏览 3提问于2014-03-31得票数 1
回答已采纳
2回答
我希望使ServiceConfiguration集合与设置集合保持同步。我(几乎)已经(几乎)使用observeChanges完成了这个任务，如下所示： changed: function (id, post) { post.hostName && (insert.host = post.hostName);
post.domainName && (insert.domain = p
浏览 0提问于2015-01-20得票数 1
回答已采纳
它不知道它订阅了谁。它只能调用取消订阅服务器。“请拔下别针退订。”不过，有两件事我并不完全清楚。内部取消订阅类是否提供订阅和遗忘行为？谁(确切地说是什么时候)在取消订阅服务器上调用IDisposable.Dispose()？垃圾收集器(GC)不是deterministic.如果我想订阅一个可观测的L1的观察者</em
浏览 0提问于2014-07-02得票数 9
1回答
最近，我一直在学习“观察者”设计模式，并了解典型的示例，如报纸通知订阅者如下： List<Subscriber是否有方法将观察者问题(或另一种设计模式)应用于通知服务(如食品递送)？
可以使用映射将每个交付订单映射到订阅服务器，但这似乎效率低下，因为它很可能是一个-> one关系。
浏览 4提问于2022-05-10得票数 0
回答已采纳
正在查看相同元素的其他客户端无法获得从服务器发送的更新值。他们只是简单地用他们的minimongo数据库中已经存在的东西进行更新。服务器端确实显示了新条目，但是除了创建它的客户端之外，我不能在任何其他客户端上查询它。
问题是我的.find使用了一个计算值的数组，因此依赖关系系统没有再次调用我的publish事件吗？
浏览 4提问于2012-12-19得票数 3
我有一个订阅，我想用它来发送事件信号，在中间件代码中。所以，我有一件事想要订阅一个可观察的，另一件事情不是完全可以观察的。return repeater.subscribe(observer);但随后我开始研究常规订阅奇怪的是，我在这里不明白的是，订阅返回有一个可用的next() -我认为next()只在可观察的上下文中生存在观察者上。无论什么情况，我都需要保持对取消订
浏览 3提问于2017-03-09得票数 3
回答已采纳
观察者订阅了可观察到的，并且立即取消了订阅。让我们假设函数createHashWithNLeadingZeroes()需要相当长的时间来生成响应。(2)当调用订阅()时，首先将观察者封装在订阅服务器对象中，然后将该订阅服务器应用于包含可观察到的逻辑的_subscribe函数。订阅服务器基本上拦截对next()、error()和complete()的调用，并且只在内部未设置属性isStopped (：
浏览 2提问于2019-12-15得票数 0
回答已采纳
1回答
从服务器订阅事件是通过SignalR完成的。然而，我们现在有几个例子，相同的可观测的共享多个观察者。处理可观察到的每个内部订阅进行得很好，但是在释放最后一个观察者之后，我想取消订阅，不接收服务器上的给定事件。我考虑过只对所有这些订阅使用单独的连接，但是在这个特定的网络环境中，在连接激活之前会有相当大的延迟。
例如，客户端应用程序的组件A、B和C都希望附加到从服务器接收到的SomeEvent。如果它是剩下的最后一个服务器</em
浏览 3提问于2013-04-17得票数 1
回答已采纳
当某些订阅者订阅一个可流动的并且这个可流动的项发送给订阅者时，每个订阅服务器能得到不同的值吗？例如，如果一个可流动的一个观察者得到0，2，另一个观察者得到1，3，等等，就像负载均衡器一样。
浏览 1提问于2016-11-10得票数 2
回答已采纳
如果我的可观察序列上没有观察者，我希望能够断开与提供价格流的远程服务器的连接，但在每个观察者都调用Dispose()之前，我不想这样做。然后，以类似的方式，当第一个人调用Subscribe时，我希望重新连接到远程服务器。
有没有办法计算出有多少观察者在一个可观察对象上调用了订阅？或者是一种知道观察者何时调用订阅或处置的方法？
浏览 1提问于2012-06-01得票数 7
在频谱的另一边，有热点可观测到的(如Subject<T>)，它们将在新的订阅出现时加入它们。还有一些温暖可观察的，就像RefCount()返回的那样，每次创建一个订阅时都会执行初始化，但前提是没有其他活动订阅。这些暖观测值的行为由Dave解释为：
或者，您可以调用发布然后调用RefCount，以获得在多个连续观察者之间共享的IObservable。当您的查询至少有一个观察者时，RefCount对底层的订阅是可以观察的。当查询没有更多的观察者</em
浏览 1提问于2018-10-04得票数 4
回答已采纳
给定这个简单的观察者和订阅者组合，它只是观察一个文件IO，然后根据值在订阅服务器中更新： }
我的问题是，在写完之前，观察者是否会阻塞即使我指定了另一个线程(IO线程)，这个观察
浏览 1提问于2015-01-21得票数 1
回答已采纳
一个可观察的人是多重价值的生产者，把他们“推”给观察者(消费者)。订阅一个可观察到的函数类似于调用一个函数。观察者是一个可观察到的价值的消费者。观察者只是一组回调，每个类型的通知都由可观察的: next、error和complete提供。下面是一个典型的观察者对象的示例：
可观察的构造函数有一个参数:订阅函数。下面的示例创建一个可观察的方法，可以每秒钟向订阅服务器发出字符串“hi”。observable.subscri
浏览 1提问于2021-04-04得票数 6
回答已采纳
1回答
为什么当我从外部调用时，只有最后一个订阅被调用，但当它在内部时，两者都被调用？有没有办法让第二个例子两者兼而有之(最好是一个可观察的，而不是一个主题)？
浏览 5提问于2017-07-18得票数 0
回答已采纳
1回答
我希望开始替换/使用RXJava2进行轮询，而不是使用观察者和侦听器。现在只有一个问题。我有一个可观察到的轮询，只有在至少一个订户被连接时才应该启动。如果连接了多个订阅服务器，则间隔应该相同。*订阅者，它应该保持轮询n秒钟，并将结果通知所有订阅者。我的第一次尝试是创建一个单例类，它只创建一个PublishSubject。如果有人被订阅，它将获得onNext()中的数据。现在，我的轮询<em
浏览 3提问于2017-04-06得票数 1
1回答
游戏网络延迟补偿
、、
我正在开发一个简单，快节奏的二维实时多人游戏在闪存.玩家只能通过射击和步行来移动时尚。我使用TCP套接字连接(AS3不提供UDP)。我知道运动矢量坐标，我可以很容易地插值他们使用延迟。然而，我想不出一种有效的方法来确定(T1)需要多长时间才能执行状态更新，然后根据T1对client2 2的屏幕进行修改。(你知道，平次可能会波动很大)。
我需要一个方法来做上述的事，我需要的方法是快速和准确的拥有，但不是非常复杂。(我应该使用什么算法？解决方案是什么?也
浏览 3提问于2012-03-05得票数 2
回答已采纳
1回答
SignalR似乎类似于观察者/发布者&订阅者模式，其中客户端订阅服务器，服务器在事件发生时向所有客户端发送通知。所以我的问题是: 1) SignalR是基于消息传递模式(即观察者/发布者和订阅者)吗？
2)如果是，那么当我们已经有一个消息传递模式时，为什么还要使用另一个消息传递模式SignalR呢？3) SignalR相对于消息传递模式(观察者/发布者和订阅者)的优势是什么
浏览 0提问于2012-04-19得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
