この擬似コードを前提として、私がやりたいのは、複数のサブスクライバーがいる場合に、remote
サブスクライバーごとに追加のポーリングでソースを飽和させないようにすることです。
IObservable<data> RemoteObservable(Remote remote)
{
var onceonly = Observable.FromAsyncPattern(remote.Begin, remote.End);
return Observable.Defer(() => onceonly())
.Repeat();
}