UV
ребят кто разбирается в rx или подобных стримах
у меня идет стрим евентов мне нужно взять только за последний час и посчитать сколько их там
я написал stream.Count().Subscribe(...)
но count у observable сработает только когда observable completed
у меня идет стрим евентов мне нужно взять только за последний час и посчитать сколько их там
я написал stream.Count().Subscribe(...)
но count у observable сработает только когда observable completed
А какой-нибудь
Timespan timespan = new DataTime(1, 0, 0);//Или как-то так
Source.TakeLast(timeSpan)
Не подойдет?
Timespan timespan = new DataTime(1, 0, 0);//Или как-то так
Source.TakeLast(timeSpan)
Не подойдет?
