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

Почему бы не реализовать его самостоятельно? Используйте TaskFactory.StartNew в цикле или рекурсивном методе while. Затем имитировать работу с помощью Task.Delay

Answer 2

То, что вы просите за это поведение по умолчанию - если вы не вводить async/await - поэтому удалите 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)) не производит значения каждую секунду - он производит интервал одной секунды между наблюдателя (ов) и заканчивая следующий стартовый.

Итак, если у вас есть длинный наблюдатель, у вас все равно будет полная секунда между одним финишем и следующим запуском.