RxJavaComputationSchedulerSensor extends AbstractHiccupSensor { @VisibleForTesting Map<String, Long> getLastPercentile(double percentile) { Map<String, Long> result = new HashMap<>(); workerTaskSchedulers.forEach(w -> { result.put(w.getThreadName(), (long) w.report(percentile)); }); return result; } @VisibleForTesting  RxJavaComputationSchedulerSensor(HiccupRecorderConfiguration configuration,
                                     long probingIntervalMs,
                                     long progressCheckIntervalMs,
                                     Registry registry);  RxJavaComputationSchedulerSensor(HiccupRecorderConfiguration configuration, Registry registry); @Override void reset(); @Override void shutdown(); void report();  }
@Test public void testExpectedNumberOfComputationThreadsIsDetected() { assertThat(sensor.getLastPercentile(99.5).keySet()).hasSize(Runtime.getRuntime().availableProcessors()); }