gistfile1.txt

Object first = Observable
      .create(s -> {
          System.out.println("hue");
          s.onNext(new Object());
          new Handler();
          s.onCompleted();
      })
      .subscribeOn(HandlerScheduler.from(new AsyncHandler("IO_HANDLER")))
      .observeOn(AndroidSchedulers.mainThread())
      .toBlocking()
      .first();