Searched refs:cancellationsByEntry (Results 1 – 1 of 1) sorted by relevance
37 val cancellationsByEntry = ConcurrentHashMap<NotificationEntry, Runnable>() in <lambda>() constant40 cancellationsByEntry.computeIfAbsent(obj) { entry -> in <lambda>()46 val cancellation = cancellationsByEntry.remove(entry) in <lambda>()53 cancellationsByEntry.remove(obj)?.run() in <lambda>()