bryan
ExecutorService executor = Executors.newFixedThreadPool(threadCt); Scheduler scheduler = Schedulers.from(executor);