Searched refs:getPendingTasks (Results 1 – 7 of 7) sorted by relevance
190 assertThat(clock.getPendingTasks(SHUTDOWN_SCHEDULED_TASK_FILTER)).isEmpty(); in returnDuplicateAddressSubchannel()192 assertThat(clock.getPendingTasks(SHUTDOWN_SCHEDULED_TASK_FILTER)).hasSize(1); in returnDuplicateAddressSubchannel()198 assertThat(clock.getPendingTasks(SHUTDOWN_SCHEDULED_TASK_FILTER)).hasSize(1); in returnDuplicateAddressSubchannel()202 assertThat(clock.getPendingTasks(SHUTDOWN_SCHEDULED_TASK_FILTER)).hasSize(2); in returnDuplicateAddressSubchannel()205 assertThat(clock.getPendingTasks(SHUTDOWN_SCHEDULED_TASK_FILTER)).hasSize(2); in returnDuplicateAddressSubchannel()
289 assertThat(fakeClock.getPendingTasks()).isEmpty(); in tearDown()635 FakeClock.ScheduledTask scheduledTask = fakeClock.getPendingTasks().iterator().next(); in abundantInitialResponse()641 assertThat(fakeClock.getPendingTasks(LOAD_REPORTING_TASK_FILTER)) in abundantInitialResponse()673 FakeClock.ScheduledTask scheduledTask = fakeClock.getPendingTasks().iterator().next(); in raceBetweenLoadReportingAndLbStreamClosure()
189 assertEquals(2, fakeClock.getPendingTasks().size()); in testTaskFilter()190 assertEquals(1, fakeClock.getPendingTasks(filter).size()); in testTaskFilter()191 assertSame(selectedRunnable, fakeClock.getPendingTasks(filter).iterator().next().command); in testTaskFilter()
249 public Collection<ScheduledTask> getPendingTasks() { in getPendingTasks() method in FakeClock250 return getPendingTasks(ACCEPT_ALL_FILTER); in getPendingTasks()256 public Collection<ScheduledTask> getPendingTasks(TaskFilter filter) { in getPendingTasks() method in FakeClock
169 Collection<ScheduledTask> pendingTimerTasks = timer.getPendingTasks(); in allPendingTasksAreRun()173 assertEquals(executor.getPendingTasks() + " should be empty", 0, executor.numPendingTasks()); in allPendingTasksAreRun()
276 assertEquals(executor.getPendingTasks() + " should be empty", 0, executor.numPendingTasks()); in allPendingTasksAreRun()2663 assertThat(timer.getPendingTasks()).isEmpty(); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()2670 assertThat(timer.getPendingTasks()).hasSize(1); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()2676 assertThat(timer.getPendingTasks()).hasSize(1); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()2689 assertThat(timer.getPendingTasks()).isEmpty(); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()2967 return Iterables.getOnlyElement(timer.getPendingTasks(NAME_RESOLVER_REFRESH_TASK_FILTER), null); in getNameResolverRefresh()
720 for (FakeClock.ScheduledTask task : fakeClock.getPendingTasks()) { in shutdownBeforeTransportCreated()931 for (FakeClock.ScheduledTask task : fakeClock.getPendingTasks()) { in resetConnectBackoff()