@Test public void evaluateExperiments () { Experiment experiment = experimentManager.addExperiment(mock(Experiment.class)); doNothing().when(experimentManager).runExperimentSteps(experiment); experimentManager.evaluateExperiments(); verify(experimentManager, times(1)).runExperimentSteps(experiment); }
void evaluateExperiments () { allExperiments.parallelStream().forEach(this::runExperimentSteps); }
ExperimentManager { void evaluateExperiments () { allExperiments.parallelStream().forEach(this::runExperimentSteps); } }
ExperimentManager { void evaluateExperiments () { allExperiments.parallelStream().forEach(this::runExperimentSteps); }  }
ExperimentManager { void evaluateExperiments () { allExperiments.parallelStream().forEach(this::runExperimentSteps); }  void setExperimentBackoffPeriod(Duration experimentBackoffPeriod); boolean areExperimentsInProgress(); }
ExperimentManager { void evaluateExperiments () { allExperiments.parallelStream().forEach(this::runExperimentSteps); }  void setExperimentBackoffPeriod(Duration experimentBackoffPeriod); boolean areExperimentsInProgress();  }