在使用RxJava开发的时候有时会遇到类似Cannot resolve method 'subscribe(anonymous io.reactivex.Observer)'的错误提示。
咋一看subscribe订阅代码并没有什么问题，但是编辑器一直提示错误。

解决方案

其实这是我们在create的时候使用了lambda表达式的缘故。
使用lambda并没有什么问题，问题在于使用lambda表达式的时候，subscribe订阅代码我们可能并没有写，这时使用lambda后代码就变成这样：

emitter -> {try {Thread.sleep(2000); // 假设此处是耗时操作} catch (Exception e) {e.printStackTrace();emitter.onError(new RuntimeException());}emitter.onNext(true);}

而在我们写完了subscribe代码后，再使用lambda转换，代码就变成：

(ObservableOnSubscribe<Boolean>) emitter -> {try {Thread.sleep(2000); // 假设此处是耗时操作} catch (Exception e) {e.printStackTrace();emitter.onError(new RuntimeException());}emitter.onNext(true);}

可以看到多了一个ObservableOnSubscribe，这是对T类型的确定。

所以一般我们使用RxJava时，如果要使用lambda表达式，需要在subscribe订阅内容完成后再进行统一转换。转换一般我们使用编辑器帮我们自动转换，windows中快捷键是alt + enter：

Cannot resolve method ‘subscribe(anonymous io.reactivex.Observer＜xxx＞)‘的解决方案相关推荐

Cannot Resolve method subscribe(anonymous org.reactivestreams.Subscriber 已解决
使用Rxjava2 出现错误: Cannot Resolve method 'subscribe(anonymous org.reactivestreams.Subscriber<Model N ...
Rxjava源码分析之IO.Reactivex.Observer
Android 中的观察者模式,Rxjava中有两个重要的类Observable和Observer,函数响应式编程具体表现为一个观察者(Observer)订阅一个可观察对象(Observable).通 ...
idea 提示Cannot resolve method 'setAttribute(java.lang.String, java.lang.String)解决方案
是由于创建了web应用但是没有导入jsp的原因找到tomcat安装的路径在Lib目录下找到 jsp-api 与 servlet -api然后导入即可
Rxjava源码分析之IO.Reactivex.Observable
Rxjava 源码系列目录 Rxjava源码分析之IO.Reactivex.Observer Rxjava源码分析之IO.Reactivex.CompositeDisposable Rxjava源码分 ...
Rxjava源码分析之IO.Reactivex.CompositeDisposable
Rxjava 源码系列目录 Rxjava源码分析之IO.Reactivex.Observer Rxjava源码分析之IO.Reactivex.CompositeDisposable Rxjava源码分 ...
Cannot resolve method addSource
原始代碼如下: ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); BatchTableEnviron ...
rx.xxx 和 io.reactivex.xxx RxJava1 和 RxJava2 和 RxJava3
在使用RxJava想要创建一个Observable,导入包的时候发现发现怎么这么多,我该选哪个? 上图 1位置的io.reactivex是代表了Rxjava2里面的Observable; 2 ...
io.reactivex.exceptions.UndeliverableException
io.reactivex.exceptions.UndeliverableException:java.net.UnknownHostException: Unable to resolve host ...
NoClassDefFoundError io.reactivex.Flowable
各路宝宝都看看这个异常: java.lang.NoClassDefFoundError: io.reactivex.Flowableat io.reactivex.Observable.bufferS ...

Cannot resolve method ‘subscribe(anonymous io.reactivex.Observer＜xxx＞)‘的解决方案

解决方案

Cannot resolve method ‘subscribe(anonymous io.reactivex.Observer＜xxx＞)‘的解决方案相关推荐

最新文章

热门文章