onNext не вызывается только на оператора - PullRequest
Новая
       7

onNext не вызывается только на оператора

0 голосов
/ 01 ноября 2018

Я использую rxjava в затмении. Я описал приведенный ниже пример. проблема, ,, когда я запускаю код, я получаю только 

onSubscribe: 0

и я не получаю никакого вывода от onNext.

пожалуйста, дайте мне знать, почему я не получаю вывод от onNext, и как это исправить

код 

public static void main(String[] args) {
    Observable<String> stringObservable = Observable.just("Hello from just Operator1");
    stringObservable
    .subscribeOn(Schedulers.newThread())
    .observeOn(Schedulers.io())
    .subscribe(new Observer<Object>() {

        @Override
        public void onComplete() {
            // TODO Auto-generated method stub
            System.out.println("onComplete: OK");
        }

        @Override
        public void onError(Throwable arg0) {
            // TODO Auto-generated method stub

        }

        @Override
        public void onNext(Object arg0) {
            // TODO Auto-generated method stub
            System.out.println("onNext: " + (String) arg0);
        }

        @Override
        public void onSubscribe(Disposable arg0) {
            // TODO Auto-generated method stub
            System.out.println("onSubscribe: " + arg0);
        }
    });
}
...