本文介绍了如何使`Defer`ed observable 只订阅第一个订阅者?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
限时送ChatGPT账号..鉴于此伪代码,我想要做的是确保如果我有多个订阅者,我不会通过对每个订阅者进行额外轮询来使我的 remote
源饱和.
Given this pseudo-code, what I'd like to do is ensure that if I have multiple subscribers, I'm not going to saturate my remote
source with extra polling for each subscriber.
IObservable<data> RemoteObservable(Remote remote)
{
var onceonly = Observable.FromAsyncPattern(remote.Begin, remote.End);
return Observable.Defer(() => onceonly())
.Repeat();
}
推荐答案
答案是RefCount
,(找到 这里):
return Observable.Defer(() => onceonly())
.Repeat()
.Publish()
.RefCount();
这篇关于如何使`Defer`ed observable 只订阅第一个订阅者?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
更多推荐
[db:关键词]
发布评论