This Java snippet shows the same behavior: ``` S...

# rx

[nhaarman]

This Java snippet shows the same behavior:

Single.just("Test")
      .subscribeOn(Schedulers.computation())
      .flatMapObservable(
            s -> {
                System.out.println("1: " + Thread.currentThread());

                return Observable.just(1)
                      .observeOn(<http://Schedulers.io|Schedulers.io>())
                      .doOnNext(o -> System.out.println("2: " + Thread.currentThread()))
                 ;
            }
      )
      .subscribe(o -> {
          System.out.println("3: " + Thread.currentThread());
      });