@HeapyHop а есть ссылки с митпаов Bkug? Скинул бы сюда, поделился.

у нас все на сайте bkug.by

Ну вот и поделился. Нужно прикрепить сюда в группу.
@Sergei_88 👆

@Sergei_88 а не пора ли и нам о сайте задуматься?

На кой нужен сайт??

У нас все материалы докладов в трелло (см правила чата, хоть их никто и не читает, иногда полезно заглянуть)

Вот вот :)

Ну сайт статус придаст.

Сайт это вообще не про статус, сейчас сайт может завести даже левая нога собачки Бреда Питта

Про погружения в байт-код. 20 февраля 19:00

JetBrains Night Moscow 2019 / События на TimePad.ru
https://jetbrains-ev-org.timepad.ru/event/892726/

Парни, помогите решить задачку:
Делаю aggregator+handler.
Идея такая - на вход идут значения, C1..delay100ms.. D1..delay500ms..C2..delay1000ms..D2..delay100ms..delay1000ms
Все входные значения группируются через аггрегатор: C to 1,2,3... D to 1,2 и тд и кладется в кэше(мапа)
Как только появился новый ключ в кэше, то handler должен его обработать через определенное время, например 1000ms

Из текущего примера:
-первое значение C1 кладется в кэш C to 1 и стартует таймер на 1000ms после окончания которого должен обработать все значения по этому ключу и очистить кэш
-поступает второе значение D1, кладется в кэш D to 1 и стартует таймер на 1000ms
-поступает C2 и кладется по существующему ключу (до обработки C осталось в данном примере 400ms, a до обработки D - 500ms)

Вопрос как бы мне так хитро таймер реализовать?

           Timer().schedule(delayMillis) {
               // some logic
           }

его через launch запускать при каждом новом ключе?

пуркуа бы и не па?

А бизнес-задача какая, чтобы понимать к чему это все?

И тайминг - строго точно 1000мс, или это  максимум?

Я так понимаю, нужнен батчеватор с группировкой по типу и ограничением по времени.

Задается

EventAggregator

Задаётся в каждом сообщении?
Или на тип сообщения?