Loading [MathJax]/jax/output/CommonHTML/config.js
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
社区首页 >问答首页 >RxJava。不能将Observable.OnSubscribe解析为类型

RxJava。不能将Observable.OnSubscribe解析为类型
EN

Stack Overflow用户
提问于 2018-06-28 09:29:17
回答 2查看 1.4K关注 0票数 0

我正在尝试用RxJava编写我的第一段代码,但我想我遇到了一些库导入错误。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
package second.pack;
import io.reactivex.Observable;
public class Main {
    public static void main(String[] args) {
        Observable <String> observable = Observable.create(
// the line below marked as it has an error in Eclipse
/* 7 line */    new Observable.OnSubscribe<String>(){
                    @Override
                    public void call (Subscriber <String> sub){
                      sub.onNext("New Datas");
                      sub.onComplete(); 
                }
            }
    );
}

}

误差

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
Exception in thread "main" java.lang.Error: Unresolved compilation problem: 
    Observable.OnSubscribe cannot be resolved to a type
    at second.pack.Main.main(Main.java:7)

拜托,有人能帮我解决这个错误吗?非常感谢!

EN

回答 2

Stack Overflow用户

回答已采纳

发布于 2018-06-28 09:58:54

您正在将结构混合在1.x和2.x之间。你是和一个老教程一起工作的吗?试一试:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
import io.reactivex.*;

public class ObservableOnSubscribeTest {
    public static void main(String[] args) {
        Observable<String> observable = Observable.create(
                new ObservableOnSubscribe<String>(){
                    @Override
                    public void subscribe(ObservableEmitter<String> sub){
                        sub.onNext("New Datas");
                        sub.onComplete(); 
                    }
                }
            );
    }
}
票数 5
EN

Stack Overflow用户

发布于 2018-06-28 09:35:34

您确定类路径上有正确版本的RxJava吗?看起来您正在尝试使用RxJava 1.x (io.reactivex.Observable),但是Observable.OnSubscribe是在RxJava 2.x (rx.Observable)中添加的

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/51088551

复制
相关文章
一篇RxJava友好的文章(一)
本文介绍了如何使用 RxJava 操作符简化 Android 代码,包括 map、filter、flatMap、take 等操作符的使用。简化复杂的逻辑,让代码更加简洁易读,提高开发效率。
方志朋
2017/12/29
8580
一篇RxJava友好的文章(一)
Rxjava源码解析笔记 | Rxjava基本用法
Rxjava四要素 被观察者 在Rxjava当中, 决定什么时候触发事件, 决定触发什么样的事件; 观察者 决定事件触发的时候将产生什么样的行为; 类似于传统观察者模式, 观察者会随着被观察者的状态变化而发生相应的操作; 订阅 区别于传统观察者模式; 观察者和被观察者需要通过订阅来联系; 通过subscribe()方法完成这个订阅关系; 完成订阅关系后, 即可令被观察者(Observable)在需要的时候, 发出事件来通知观察者(Observer) 事件 区别于传统观察者模式;
凌川江雪
2019/06/05
6920
RxJava2 解析
通过ObservableEmitter 被观察者的发射器,做发送数据、错误、完成等操作,是一个接口,继承自Emitter。
Yif
2019/12/26
1.3K0
RxJava系列二(基本概念及使用介绍)
前言 上一篇的示例代码中大家一定发现了Observable这个类。从纯Java的观点看,Observable类源自于经典的观察者模式。RxJava的异步实现正是基于观察者模式来实现的,而且是一种扩展的观察者模式。 观察者模式 观察者模式基于Subject这个概念,Subject是一种特殊对象,又叫做主题或者被观察者。当它改变时那些由它保存的一系列对象将会得到通知,而这一系列对象被称作Observer(观察者)。它们会对外暴漏了一个通知方法(比方说update之类的),当Subject状态发生变化时会调用
张磊BARON
2018/04/13
9720
RxJava系列二(基本概念及使用介绍)
Swift Codable 将任意类型解析为想要的类型
默认情况下,使用 Swift 内置的 Codable API 解析 JSON 时,我们的属性类型需要和Json 中的类型保持一致,否则就会解析失败。
韦弦zhy
2021/11/24
2K0
RxJava 1.x 笔记:创建型操作符
本篇文章是阅读 官方文档 的笔记。  作者:shixinzhang RxJava 也用了有段时间,那么多操作符总不想去记,遇到了才去查一下,查的次数多了感觉效率太低,还不如先过一遍官方文档。 因此接下
张拭心 shixinzhang
2018/01/05
1.1K0
RxJava 1.x 笔记:创建型操作符
Rxjava解析笔记 | Rxjava概述 & 传统观察者设计模式解析
比如:在后台做一些网络操作、查询或者一些复杂计算的时候, 我们如果不用其他框架的话, 最常见做法即自己开一个子线程, 然后通过回调的形式获取到结果(如后台以结果为参数发送广播,前台回调onReceive()接收获取到结果); 但是这样有一个问题, 随着业务逻辑越来越复杂, 项目会陷入回调中套回调的病区, 这对后期维护代码来说是一个很严重的问题;
凌川江雪
2019/06/03
5010
RxJava 完全解析 是时候来进阶 RxJava 了!
我们知道RxJava是Android项目最重要的库。因此,我们必须正确掌握在Android项目中使用RxJava。
圆号本昊
2021/09/24
1.1K0
RxJava 完全解析 是时候来进阶 RxJava 了!
Rxjava源码解析笔记 | 创建Observable 与 Observer/Subscriber 以及之间订阅实现的源码分析
接下来是Rxjava的SDK中subscribe()的传入参数 是Observer时候(observable.subscribe(observer);)的源码:
凌川江雪
2019/06/11
1.6K0
RxJava系列六(从微观角度解读RxJava源码)
前言 通过前面五个篇幅的介绍,相信大家对RxJava的基本使用以及操作符应该有了一定的认识。但是知其然还要知其所以然;所以从这一章开始我们聊聊源码,分析RxJava的实现原理。本文我们主要从三个方面来分析RxJava的实现: RxJava基本流程分析 操作符原理分析 线程调度原理分析 本章节基于RxJava1.1.9版本的源码 一、RxJava执行流程分析 在RxJava系列2(基本概念及使用介绍)中我们介绍过,一个最基本的RxJava调用是这样的: 示例A Observable.create(new
张磊BARON
2018/04/13
1.6K0
RxJava系列六(从微观角度解读RxJava源码)
RxJava从入门到不离不弃(五)——Scheduler线程调度
在不指定线程的情况下, RxJava 遵循的是线程不变的原则,即:在哪个线程调用 subscribe(),就在哪个线程生产事件;在哪个线程生产事件,就在哪个线程消费事件。如果需要切换线程,就需要用到 Scheduler (调度器)。
蜻蜓队长
2018/11/07
1.2K0
Rxjava实战笔记 | Rxjava的基本使用解析(同步结合示例)
Observable和Observer通过subscribe()方法实现订阅关系; Rxjava中是自动发送事件的, 一旦订阅就开始发送;
凌川江雪
2019/06/13
2.4K0
体验RxJava和lambda
程序员欣宸
2018/01/04
1K0
体验RxJava和lambda
java中无法解析为类型_java无法解析导入的包
.odt文件是openoffice软件产生的文档格式,可以直接用office打开,这其实就是一个压缩包,可以使用解压软件打开,里面有一个content.xml文件,这个文件内有<text:p>标签,标签内就是展示出来的内容。
全栈程序员站长
2022/10/28
4.8K0
关于RxJava的基础心法解析
2016年学习过一阵子RxJava的操作符也做过一些笔记,我们项目的网络请求框架也替换成了Okhttp+Retrofit,所以使用RxJava做线程间切换就非常好用。
静默加载
2020/05/29
4380
Android :RxJava2.0到底更新了什么?(含使用建议)
在`RxJava 2.0 `中,创建被观察者(`Observable`) & 观察者(Observer)的方式也与`RxJava 1.0 `有些区别:
Carson.Ho
2019/02/22
1K0
RXJava原理_JavaScript的执行原理
既然rxjava是基于观察者来组建自己的逻辑的,那么我们就来创建观察者(Observer/Subscriber),被观察者(Observable),然后二者建立订阅的关系(就好像那根电线连接台灯和开关)实现台灯观察开关的具体模式,并且在传递过程中对事件进行处理(比如:降低电压)。 Tips: Observer是观察者的接口,Subscriber是实现该接口的抽象类,因此这两个类都可以作为观察者,只是Subscriber在Observer的基础上加入了一下拓展,加入了新的一些方法,所以一般更倾向于Subscriber作为观察者,下面我们就来敲一遍:
全栈程序员站长
2022/11/01
6990
RXJava原理_JavaScript的执行原理
【Android】RxJava的使用(四)线程控制 —— Scheduler
前言 经过前几篇的介绍,对RxJava对模式有了一定的理解:由Observable发起事件,经过中间的处理后由Observer消费。(对RxJava还不了解的可以出门左拐) 之前的代码中,事件的发起和消费都是在同一个线程中执行,也就是说之前我们使用的RxJava是同步的~~~ 观察者模式本身的目的不就是后台处理,将处理结果回调给前台?这同步的是要哪样?所以,这篇为大家介绍RxJava的重要的概念——Scheduler 参考:给 Android 开发者的 RxJava 详解 (本文部分内容引用自该博
Gavin-ZYX
2018/05/18
7160
Carson带你学Android:RxJava2.0到底更新了什么?
在RxJava 2.0中,创建被观察者(Observable) & 观察者(Observer)的方式也与RxJava 1.0有些区别:
Carson.Ho
2022/03/24
4730
Carson带你学Android:RxJava2.0到底更新了什么?
All RxJava - 为Retrofit添加重试
在我们的日常开发中离不开I/O操作,尤其是网络请求,但并不是所有的请求都是可信赖的,因此我们必须为APP添加请求重试功能。
小鄧子
2018/08/20
1.7K0
All RxJava - 为Retrofit添加重试

相似问题

不能将GeofencingRequest解析为类型

22

不能将Rest解析为类型

32

不能将GoogleCloudMessaging解析为类型

95

不能将EmbeddedDataSource解析为类型

12

不能将HttpJUnitRunner解析为类型

13
添加站长 进交流群

领取专属 10元无门槛券

AI混元助手 在线答疑

扫码加入开发者社群
关注 腾讯云开发者公众号

洞察 腾讯核心技术

剖析业界实践案例

扫码关注腾讯云开发者公众号
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
查看详情【社区公告】 技术创作特训营有奖征文