在 RxAndroid 中创建观察者时出错

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() {

    }
});