These are the observers used within the Observables that showcase the defualt use of the computation scheduler.

medium-computation-scheduler:rxjava2_observers_for_operator.java

/************************** OBSERVERS ***************************************/

 private Observer<String> stringObserver =  new Observer<String>() {
        @Override
        public void onSubscribe(Disposable d) {
            Log.e("RxJava2:Schedulers: " , "onSubscribe | " +  Thread.currentThread().getName());
        }

        @Override
        public void onNext(String message) {
            Log.e("RxJava2:Schedulers: ", "onNext | " +  message);
            Log.e("RxJava2:Schedulers: ", "onNext | " +  Thread.currentThread().getName());
        }

        @Override
        public void onError(Throwable e) {
            Log.e("RxJava2:Schedulers: ", "onError | "+  Thread.currentThread().getName());
        }

        @Override
        public void onComplete() {
            Log.e("RxJava2:Schedulers: ", "onComplete | " +  Thread.currentThread().getName());
        }
    };

    private Observer<Long> longObserver =  new Observer<Long>() {
        @Override
        public void onSubscribe(Disposable d) {
            Log.e("RxJava2:Schedulers: " , "onSubscribe | " +  Thread.currentThread().getName());
        }

        @Override
        public void onNext(Long message) {
            Log.e("RxJava2:Schedulers: ", "onNext | " +  message);
            Log.e("RxJava2:Schedulers: ", "onNext | " +  Thread.currentThread().getName());
        }

        @Override
        public void onError(Throwable e) {
            Log.e("RxJava2:Schedulers: ", "onError | "+  Thread.currentThread().getName());
        }

        @Override
        public void onComplete() {
            Log.e("RxJava2:Schedulers: ", "onComplete | " +  Thread.currentThread().getName());
        }
    };

/********************************* END OBSERVERS ********************************************/