Searched refs:threadAccumulator (Results 1 – 2 of 2) sorted by relevance
182 ThreadAccumulator threadAccumulator = component.threadAccumulator().get(); in monitoringWithThreads() local198 .isEqualTo(threadAccumulator.threadId("entryPoint")); in monitoringWithThreads()200 .isEqualTo(threadAccumulator.threadId("entryPoint")); in monitoringWithThreads()203 assertThat(deferredMonitor.requestedThreadId).isEqualTo(threadAccumulator.threadId("required")); in monitoringWithThreads()204 assertThat(deferredMonitor.startingThreadId).isEqualTo(threadAccumulator.threadId("deferred")); in monitoringWithThreads()205 assertThat(deferredMonitor.finishedThreadId).isEqualTo(threadAccumulator.threadId("deferred")); in monitoringWithThreads()209 assertThat(requiredMonitor.startingThreadId).isEqualTo(threadAccumulator.threadId("required")); in monitoringWithThreads()210 assertThat(requiredMonitor.finishedThreadId).isEqualTo(threadAccumulator.threadId("required")); in monitoringWithThreads()216 threadAccumulator.threadId("required"), in monitoringWithThreads()217 threadAccumulator.threadId("deferred"), in monitoringWithThreads()[all …]
29 ListenableFuture<ThreadAccumulator> threadAccumulator(); in threadAccumulator() method