Я довольно новичок в RX Java и реактивном программировании.
У меня есть поток запросов, которые мне нужно сгруппировать по IP-адресам
[Start-timestamp] [reqId] [ip-address]
Observable<GroupedObservable<String, Trace>> groupedEntriesObservable =
windowedLogEntries.groupBy(trace-> trace.getIP());
но как я могу получить только те, которые находятся на расстоянии 5 мс от начальной отметки времени их первой? Например,
, поэтому, если у меня есть
{0ms,id1,ip1}, {1ms,id2,ip1}....{3ms,id3,ip1}, {7ms,id4,ip1}....{15ms,id5,ip1}
, то отфильтрованная группа будет иметь вид:
{id1,id2,id3}
остальные отклоняются, поскольку их метка времени больше 0 мс + 5 мс