Searched refs:getTaskQueue (Results 1 – 2 of 2) sorted by relevance
241 mDataBroker.getTaskQueue().add(mLowPriorityTask); in testSetTaskExecutionPriority_whenNextTaskPriorityLow_shouldNotRunTask()247 assertThat(mDataBroker.getTaskQueue().peek()).isEqualTo(mLowPriorityTask); in testSetTaskExecutionPriority_whenNextTaskPriorityLow_shouldNotRunTask()254 mDataBroker.getTaskQueue().add(mHighPriorityTask); in testSetTaskExecutionPriority_whenNextTaskPriorityHigh_shouldInvokeScriptExecutor()260 assertThat(mDataBroker.getTaskQueue().peek()).isNull(); in testSetTaskExecutionPriority_whenNextTaskPriorityHigh_shouldInvokeScriptExecutor()275 PriorityBlockingQueue<ScriptExecutionTask> taskQueue = mDataBroker.getTaskQueue(); in testScheduleNextTask_whenTaskInProgress_shouldNotInvokeScriptExecutorAgain()295 mDataBroker.getTaskQueue().add(mHighPriorityTask); in testScheduleNextTask_onScriptSuccess_shouldStoreInterimResult()302 assertThat(mDataBroker.getTaskQueue().peek()).isNull(); in testScheduleNextTask_onScriptSuccess_shouldStoreInterimResult()310 mDataBroker.getTaskQueue().add(mHighPriorityTask); in testScheduleNextTask_onScriptError_shouldStoreErrorObject()333 mDataBroker.getTaskQueue().add(mHighPriorityTask); in testScheduleNextTask_whenScriptFinishes_shouldStoreFinalResult()349 mDataBroker.getTaskQueue().add(mHighPriorityTask); in testScheduleNextTask_whenScriptProducesReport_shouldStoreFinalResult()[all …]
437 PriorityBlockingQueue<ScriptExecutionTask> getTaskQueue() { in getTaskQueue() method in DataBrokerImpl