Я использую rxjava в eclipse. Я создал приведенный ниже пример. проблема в том, что когда я запускаю код, я получаю только
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);
}
});
}
@akarnokd в ссылке, которую вы мне прислали, есть пример следующего, а не наблюдаемого ... не могли бы вы помочь мне решить эту проблему
Продолжайте читать, и он, скорее всего, ответит и на ваш следующий вопрос SO.





Предлагаемое чтение: github.com/ReactiveX/RxJava#hello-world. Пожалуйста, прочтите весь раздел «Начало работы» от начала до конца.