У меня есть наблюдаемая последовательность, которая генерирует события, которые имеют свою собственную метку времени. Я использую HistoricalScheduler для продвижения часов планировщика на основе метки времени. Теперь мне нужно буферизовать эти события в абсолютное время (например, каждые 5 минут) планировщика, например
S -> --A-B-C ----- D --- E - F ---
Часы -> 0 -------- 5 -------- 10 -------
Результат-> --------- A --------- D
B E
C
Я попытался использовать метод Generate и использовать перечислитель для перемещения последовательности, добавив время 5 минут к начальному значению 0-5-10-15, чтобы сгенерировать последовательность, и эти события привели к закрытию буфера и открытию нового для открыт.
Однако проблема в том, что события генерируются не синхронно с часами планировщика, поэтому 0-5-10 генерируются до того, как планировщик достигнет 5 минут, 10 минут.
Пожалуйста, предложите, что я могу сделать?
Заранее спасибо!
H