code: public void start() {
          FixedSchedulerPool update = new FixedSchedulerPool(poolSize);
          if (!pool.compareAndSet(NONE, update)) {
              update.shutdown();
          }
      }
docs: TODO when depending on RxJava 1.0.15+, this would be an @Override