@Test public void eachPipelineContainsDistinctExecutor() { long numberOfExecutors = this.ps.pipelines().stream().map(s -> s.getExecutor()).distinct().count(); long numberOfStatistics = this.ps.getAllStatistics().size(); assertThat(numberOfExecutors, is(numberOfStatistics)); }
@Produces public List<Statistics> getAllStatistics() { return this.ps.getAllStatistics(); }
ExecutorServiceExposer { @Produces public List<Statistics> getAllStatistics() { return this.ps.getAllStatistics(); } }
ExecutorServiceExposer { @Produces public List<Statistics> getAllStatistics() { return this.ps.getAllStatistics(); }  }
ExecutorServiceExposer { @Produces public List<Statistics> getAllStatistics() { return this.ps.getAllStatistics(); }  void onRejectedExecution(Runnable r, ThreadPoolExecutor executor); @Produces @Dedicated ExecutorService exposeExecutorService(InjectionPoint ip); @Produces @Dedicated Statistics exposeStatistics(InjectionPoint ip); @Produces List<Statistics> getAllStatistics(); }
ExecutorServiceExposer { @Produces public List<Statistics> getAllStatistics() { return this.ps.getAllStatistics(); }  void onRejectedExecution(Runnable r, ThreadPoolExecutor executor); @Produces @Dedicated ExecutorService exposeExecutorService(InjectionPoint ip); @Produces @Dedicated Statistics exposeStatistics(InjectionPoint ip); @Produces List<Statistics> getAllStatistics();  }