Single.just(10) .doOnDispose(() -> Log.i("TEST", "dispose")) compose(bindUntilEvent(ActivityEvent.CREATE)) .observeOn(AndroidSchedulers.mainThread()) .subscribe( i -> Log.i("TEST", String.valueOf(i)), throwable -> Log.i("TEST", throwable.t…