ну один поток данных я слушаю, и собираю количество проходящих через себя ивентов. Но я хочу счётчик сбрасывать, например, после интервала времени и уже дальше пускать значение которое я насчитала в себе. Кажется всё же надо писать свой оператор
ну один поток данных я слушаю, и собираю количество проходящих через себя ивентов. Но я хочу счётчик сбрасывать, например, после интервала времени и уже дальше пускать значение которое я насчитала в себе. Кажется всё же надо писать свой оператор