void (@NotNull RunnablesListener publisher) { myEventsByClass.forEach((eventClass, events) -> publisher.eventsProcessed(eventClass, joinPolling(events))); publisher.runnablesProcessed(joinPolling(myRunnables), myDurationsByFqn.values(), myWrappers.values()); }