Searched refs:getTaskQueue (Results 1 – 2 of 2) sorted by relevance
236 mDataBroker.getTaskQueue().add(mLowPriorityTask); in testSetTaskExecutionPriority_whenNextTaskPriorityLow_shouldNotRunTask()242 assertThat(mDataBroker.getTaskQueue().peek()).isEqualTo(mLowPriorityTask); in testSetTaskExecutionPriority_whenNextTaskPriorityLow_shouldNotRunTask()249 mDataBroker.getTaskQueue().add(mHighPriorityTask); in testSetTaskExecutionPriority_whenNextTaskPriorityHigh_shouldInvokeScriptExecutor()255 assertThat(mDataBroker.getTaskQueue().peek()).isNull(); in testSetTaskExecutionPriority_whenNextTaskPriorityHigh_shouldInvokeScriptExecutor()270 PriorityBlockingQueue<ScriptExecutionTask> taskQueue = mDataBroker.getTaskQueue(); in testScheduleNextTask_whenTaskInProgress_shouldNotInvokeScriptExecutorAgain()290 mDataBroker.getTaskQueue().add(mHighPriorityTask); in testScheduleNextTask_onScriptSuccess_shouldStoreInterimResult()297 assertThat(mDataBroker.getTaskQueue().peek()).isNull(); in testScheduleNextTask_onScriptSuccess_shouldStoreInterimResult()305 mDataBroker.getTaskQueue().add(mHighPriorityTask); in testScheduleNextTask_onScriptError_shouldStoreErrorObject()328 mDataBroker.getTaskQueue().add(mHighPriorityTask); in testScheduleNextTask_whenScriptFinishes_shouldStoreFinalResult()344 mDataBroker.getTaskQueue().add(mHighPriorityTask); in testScheduleNextTask_whenScriptProducesReport_shouldStoreFinalResult()[all …]
443 PriorityBlockingQueue<ScriptExecutionTask> getTaskQueue() { in getTaskQueue() method in DataBrokerImpl