メソッドを繰り返し呼び出すobservableを作成します

Question

プロパティ値を繰り返し取得して別のプロパティに割り当てることはしたいのですが、RxのObservable作成はまだ処理されていません。どのようにしてプロパティを常時読み取っているオブザーバブルを作成したり購読したりするにはどうすればいいでしょうか（おそらくタイマーやスロットルで）？

Answer 1

スタティックInterval演算子を使用して、指定された時間間隔で値を繰り返し送信し、次にSelectオペレータを使用して、ポーリングするオブジェクトのプロパティ値に変換できます。

var objectIWantToPoll = new MyObject(); 
var objectIWantToSetPropertyOn = new MyObject(); 


var polledValues = Observable.Interval(TimeSpan.FromSeconds(1)) 
    .Select(_ => objectIWantToPoll.SomeProperty); 

polledValues.Subscribe(propertyValue => 
    objectIWantToSetPropertyOn.SomeProperty = propertyValue)); 

Answer 2

いくつかのコンポーネントが変更された値をポーリングするポーリング実装を基本的に求めているようです。オブザーバブルは通常、値を取得するのではなく、（イベント/オブザーバブル/などを介して）プッシュされたオブジェクトに反応するためのものです。おそらく、タイマーのバックグラウンドプロセスを設定し、そのタイマーのTickで操作するだけで十分です。 Observable.IntervalはJames Hayが言及したのと同様に動作します。 Observable.Intervalはディスパッチャスレッドから実行コンテキストを移動することに注意してください。

なぜRxをポーリングの実装に入れようとしていますか？ここで同期しようとしている他の観測可能なデータソースがありますか？

Answer 3

public static IObservable<long> CreateObservableTimerWithAction(this Action actionT, int timeSpan, Control control) 
    { 
     var obs = Observable.Create<long>(
      observer => 
      { 
       Observable.Interval(TimeSpan.FromMilliseconds(timeSpan)) 
.DistinctUntilChanged(fg =>control.Text).Subscribe(l => actionT()); 
       return Disposable.Empty; 
      }); 

     return obs; 
    } 

0R：

public static IObservable<long> CreateObservableTimer<T>(this Action actionT,int timeSpan) 
    { 
     var obs= Observable.Create<long>(
      observer => 
      { 
       Observable.Interval(TimeSpan.FromMilliseconds(timeSpan)) 
.DistinctUntilChanged().Subscribe(l => actionT()); 
       return Disposable.Empty; 
      }); 
     return obs; 
    } 

私は（obs.Dispose（））に処分されるまで時間指定の方法は、特定の時間に行く持って、かなり頻繁にこれを使用..

CreateObservableTimer（（）=> CheckForDequeues（1）、500）;

私は実際に時々長いを使用しますが、時間のほとんどは、ない...

がさえプライオリティキューにスケジューラをチェックするために、このヘルパーを使うので、