Я попытался создать пользовательский реактивный таймер с динамическими интервалами в C# с использованием библиотеки RX. Поскольку мне нужен наиболее оптимизированный код как в производительности, так и в нет. линий я закончил тем, что использовал рекурсивный подход. Код ниже: < /p>
public static IObservable GenerateAsync(
Func initialState,
Func condition,
Func iterate,
Func timeSelector,
Func resultSelector,
IScheduler scheduler = null)
{
var s = scheduler ?? Scheduler.Default;
return Observable.Create(async obs =>
{
//You have to do your initial time delay here.
var init = await initialState();
//Process the result
obs.OnNext(resultSelector(init));
return s.Schedule(init, timeSelector(init), async (state, recurse) =>
{
//Check if we are done
if (!condition(state))
{
obs.OnCompleted();
return;
}
//Initiate the next request
state = await iterate(state);
//Process the result
obs.OnNext(resultSelector(state));
//Recursively schedule again
recurse(state, timeSelector(state));
});
});
}
< /code>
Проблема с этим подходом заключается в том, что, поскольку он рекурсивный, следовательно, существует огромный рост стека. Я протестировал этот подход против использования таймера, и его использование памяти почти вдвое.>
Подробнее здесь: https://stackoverflow.com/questions/338 ... e-function
