JobExecutor implements ThreadExecutor { @Override public Scheduler getScheduler() { return Schedulers.io(); } @Inject  JobExecutor(); @Override Scheduler getScheduler();  }
@Test public void getSchedulerShouldReturnIoScheduler() { JobExecutor jobExecutor = new JobExecutor(); assertEquals(Schedulers.io(), jobExecutor.getScheduler()); }