### Question:
PipelineExecutorTaskManagerImplHelper { public PipelineExecutor createPipelineExecutor() { final Collection<ConfigExecutor> configs = new ArrayList<>(); configExecutorInstance.iterator().forEachRemaining(configs::add); return newPipelineExecutor(configs); } PipelineExecutorTaskManagerImplHelper(final Instance<ConfigExecutor> configExecutorInstance,
                                                 final Instance<PipelineEventListener> pipelineEventListenerInstance); ExecutorService createExecutorService(); PipelineExecutor createPipelineExecutor(); List<PipelineEventListener> createExternalListeners(); void notifyExternalListeners(final List<PipelineEventListener> externalListeners,
                                        final PipelineEvent event); PipelineExecutorTaskImpl createTask(final PipelineExecutorTaskDef taskDef); PipelineExecutorTaskImpl createTask(final PipelineExecutorTaskDef taskDef,
                                               final String executionId); String generateTaskId(); void setTaskInStoppedStatus(final PipelineExecutorTaskImpl task);  }### Answer:
@Test public void testCreatePipelineExecutor() { assertNotNull(taskManagerHelper.createPipelineExecutor()); verify(configExecutorsInstance, times(1)).iterator(); verify(taskManagerHelper, times(1)).newPipelineExecutor(configExecutors); }