Я получаю события с такой структурой:
class Data
{
public int counter;
public int type;
public int timestamp;
}
Задача:
Подождать какой-то период времени, чтобы получить несколько событий.
Отсортировать все по возрастающим значениям counter.
Найти смежные данные : counter, counter + 1.
Если timestamp2 — timestamp1 меньше T и type первого 0 , а второго 1 , то выдать новое событие.
Далее эти данные отбрасываются как ненужные, чтобы counter+1, counter+2 не сгенерировало еще событие
Вручную все описывается несложно, поток, очередь и проверки.
Возможно ли в этой ситуации применить Rx чтобы получить более декларативный код ?
