1

この擬似コードを前提として、私がやりたいのは、複数のサブスクライバーがいる場合に、remoteサブスクライバーごとに追加のポーリングでソースを飽和させないようにすることです。

IObservable<data> RemoteObservable(Remote remote) 
{
   var onceonly = Observable.FromAsyncPattern(remote.Begin, remote.End);
   return Observable.Defer(() => onceonly())
                    .Repeat();
}
4

1 に答える 1

2

答えはRefCount、(ここにあります):

   return Observable.Defer(() => onceonly())
                    .Repeat()
                    .Publish()
                    .RefCount();
于 2012-07-27T08:43:13.307 に答える