如何使`Defer`ed observable 只订阅第一个订阅者?

本文介绍了如何使`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屋！