在 RxAndroid 中创建 Observer 时出错

Question

我正在使用 RxAndroid 制作示例，如下面的代码所示。但是 Android studio 给出了以下错误：

incompatible types
required: io.reactivex.observable <String>
found: void

请告诉我如何解决这个错误

代码:

Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
        @Override
        public void subscribe(ObservableEmitter<String> e) throws Exception {
            e.onNext("onNext");
            e.onComplete();

        }
    }).subscribe(new Observer<String>() {
        @Override
        public void onSubscribe(Disposable d) {

        }

        @Override
        public void onNext(String value) {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onComplete() {

        }
    });

Answer 1

将创建和订阅拆分为不同的语句：

Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
    @Override
    public void subscribe(ObservableEmitter<String> e) throws Exception {
        e.onNext("onNext");
        e.onComplete();

    }
});

observable.subscribe(new Observer<String>() {
    @Override
    public void onSubscribe(Disposable d) {

    }

    @Override
    public void onNext(String value) {

    }

    @Override
    public void onError(Throwable e) {

    }

    @Override
    public void onComplete() {

    }
});

在 RxAndroid 中创建 Observer 时出错

Error when creating Observer in RxAndroid

android

rx-java

rx-android