Observable.Intervalはアクションが完了するまで待機します。

Question

Observable.Intervalは毎回値を生成します。アクションが次の繰り返しの前に終了するまで待つ方法

例：

Observable.Interval(TimeSpan.FromSeconds(1)).Subscribe(async t => 
{ 
    //Here could be some long running action with different duration each iteration 
    Console.WriteLine(t.ToString()); 
    await Task.Delay(3000); 
}); 

それは、アクションを毎秒を開始します。アクションが完了するまで待つ方法

Answer 1

自分で実装してみませんか？ whileループまたは再帰的な方法でTaskFactory.StartNewを使用してください。あなたはasync/awaitを導入しない限り - - は次に何を求めていることは、デフォルトの動作ですTask.Delay

Answer 2

を使用して作業をシミュレートするので、asyncを削除し、代わりにTask.Delay(3000).Wait()を使用しています。

Observable.Interval(TimeSpan.FromSeconds(1)).Subscribe(t => 
{ 
    //Here could be some long running action with different duration each iteration 
    Console.WriteLine(t.ToString()); 
    Task.Delay(3000).Wait(); 
}); 

オブザーバーが終わったら、観測のための契約は、新しい値を生成します - あなたはasyncを紹介していない限り。

Observable.Interval(TimeSpan.FromSeconds(1))は、すべての第2の値を生成しない - それは、間隔間第1の観察者（単数または複数）、仕上げと次の起動を生じさせます。

だから、あなたが長時間走っているオブザーバーを持っていれば、1回のフィニッシングと次のスタートの間に完全な秒があります。