Searched refs:ThreadRecordingProducerMonitor (Results 1 – 1 of 1) sorted by relevance
185 ImmutableList<Map.Entry<ProducerToken, ThreadRecordingProducerMonitor>> entries = in monitoringWithThreads()189 ThreadRecordingProducerMonitor entryPointMonitor = entries.get(0).getValue(); in monitoringWithThreads()191 ThreadRecordingProducerMonitor requiredMonitor = entries.get(1).getValue(); in monitoringWithThreads()193 ThreadRecordingProducerMonitor deferredMonitor = entries.get(2).getValue(); in monitoringWithThreads()224 final Map<ProducerToken, ThreadRecordingProducerMonitor> monitors = new LinkedHashMap<>();228 ThreadRecordingProducerMonitor monitor = new ThreadRecordingProducerMonitor(); in producerMonitorFor()234 private static final class ThreadRecordingProducerMonitor extends ProducerMonitor { class in MonitoringTest