文档建议反馈控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Carson带你学Android：RxJava操作符教程

RxJava 实际应用讲解：网络请求嵌套回调 3.3 组合 / 合并操作符 作用 组合 多个被观察者（Observable） & 合并需要发送的事件 应用场景 组合多个被观察者 合并多个事件...Android RxJava 实际应用讲解：从磁盘 / 内存缓存中 获取缓存数据 Android RxJava 实际应用讲解：联合判断 3.4 功能性操作符 作用 辅助被观察者（Observable...） Android RxJava 实际应用讲解：（有条件）网络请求轮询 3.5 过滤操作符 作用 过滤 / 筛选 被观察者（Observable）发送的事件 & 观察者 （Observer）接收的事件...联想搜索优化 Android RxJava 实际应用讲解：Android RxJava 实际应用讲解：功能防抖 3.6 条件 / 布尔操作符 作用 通过设置函数，判断被观察者（Observable...）发送的事件是否符合条件 类型 RxJava2中，条件 / 布尔操作符的类型包括： 具体操作符详解 Android RxJava：详解 条件 / 布尔操作符 至此，关于RxJava 2

66320

Android： RxJava操作符 详细使用手册

RxJava 实际应用讲解：网络请求嵌套回调 3.3 组合 / 合并操作符 作用 组合 多个被观察者（Observable） & 合并需要发送的事件 应用场景 组合多个被观察者 合并多个事件...RxJava 实际应用讲解：从磁盘 / 内存缓存中 获取缓存数据 Android RxJava 实际应用讲解：联合判断 3.4 功能性操作符 作用 辅助被观察者（Observable） 在发送事件时实现一些功能性需求...实际应用场景 连接（订阅） 观察者 & 被观察者 线程调度（切换） 错误处理 事件生命周期操作 延时操作 重复发送操作 类型 根据上述应用场景，常见的功能性操作符 主要有： 具体操作符...全面讲解 实际开发需求案例 下面，我将讲解组合操作符的常见实际需求案例 该例子将结合Retrofit 和 RxJava 进行讲解 3.6 条件 / 布尔操作符 作用 通过设置函数，...判断被观察者（Observable）发送的事件是否符合条件 类型 RxJava2中，条件 / 布尔操作符的类型包括： 具体操作符详解 Android RxJava：详解 条件 / 布尔操作符 至此

1.5K20
    • 您找到你想要的搜索结果了吗？
    是的
    没有找到

    十六、Hystrix断路器：初体验及RxJava简介

    ---- 核心概念 注意：以下讲解、示例均基于1.x版本 它的核心思想和Java的观察者模式非常像：被观察者和观察者通过订阅产生一种关系，当被观察者发生一些改变，通知观察者，观察者对应做出相应的回应...主要有三个关键词需要记住：被观察者（Observable），订阅（subscribe），观察者（Observer）。...Observable（被观察者，也就是数据发射器）：public class Observable代表一个被观察对象 Observer（观察者，也就是数据接收器） ：public interface...---- 总结 关于Netflix Hystrix断路器：初体验及RxJava简介就先介绍到这，通过本文能了解到如下两部分知识： Hystrix是什么，有何用，怎么用？...RxJava是什么，有何用，怎么用？ 当然，怎么用是个较大的话题，关于RxJava怎么用就先止步于此，有兴趣的小朋友自行研究。

    2.3K31

    RxJava 完全解析 是时候来进阶 RxJava 了！

    什么是RxJava？ RxJava用于反应式编程。在反应式编程中，消费者在数据进入时作出反应。反应式编程允许事件更改传播给已注册的观察者。 我们知道RxJava是Android项目最重要的库。...---- 让我们看看所有可用于以最佳方式学习RxJava的最佳资源 完整的 RxJava 教程 RxJava是Reactive Extensions的Java VM实现。...学习 RxJava ---- 通过范例学习 RxJava 因为 通过实例学习是最好的学习方式。 它包含许多例子，例如： 如何在RxJava中使用运算符？ 如何在RxJava中进行联网？...如何在RxJava中实现RxBus（EventBus）？ 如何用RxJava实现分页？ 从这里学习。...---- 理解RxJava中的Observable类型 了解RxJava主题 - 发布，重播，行为和异步主题 ---- 学习“如何使用RxJava操作符实现缓存” 缓存在以下情况下非常有用： 减少网络呼叫

    1.1K20

    Carson带你学Android：RxJava线程控制(含实例讲解)

    RxJava线程控制（调度 / 切换）的作用是什么？ 指定 被观察者 （Observable） / 观察者（Observer） 的工作线程类型。 2....2.1 背景 在 RxJava模型中，被观察者 （Observable） / 观察者（Observer）的工作线程 = 创建自身的线程 即，若被观察者 （Observable） / 观察者（Observer...（） & observeOn（）简介 作用 线程控制，即指定 被观察者 （Observable） / 观察者（Observer） 的工作线程类型 线程类型 在 RxJava中，内置了多种用于调度的线程类型...）：指定被观察者 发送事件的线程（传入RxJava内置的线程类型） // Observable.observeOn（Schedulers.Thread）：指定观察者 接收 & 响应事件的线程（传入RxJava.../布尔操作符 应用 Carson带你学Android：什么时候应该使用Rxjava？

    91020

    Carson带你学Android：RxJava过滤操作符

    作用 过滤 / 筛选 被观察者（Observable）发送的事件 & 观察者 （Observer）接收的事件 2....'io.reactivex.rxjava2:rxjava:2.0.7' // 注：RxJava2 与 RxJava1 不能共存，即依赖不能同时存在 } 3.1 根据 指定条件 过滤事件...5个事件，只是因为操作符的存在拦截了3个事件，最终观察者接收到的是2个事件 测试结果 takeLast（） 作用 指定观察者只能接收到被观察者发送的最后几个事件 具体使用 Observable.just...仅发送在该时间内的事件 对应操作符类型 对应操作符使用 throttleFirst（）/ throttleLast（） 作用 在某段时间内，只发送该段时间内第1次事件 / 最后1次事件 如，...Demo地址 上述所有的Demo源代码都存放在：Carson_Ho的Github地址：RxJava2_过滤操作符 6. 总结 下面，我将用一张图总结 RxJava2 中常用的条件 / 布尔操作符

    60620

    Android RxJava 操作符详解系列：过滤操作符

    如果还不了解 RxJava，请看文章：Android：这是一篇 清晰 & 易懂的Rxjava 入门教程 RxJava如此受欢迎的原因，在于其提供了丰富 & 功能强大的操作符，几乎能完成所有的功能需求...作用 过滤 / 筛选 被观察者（Observable）发送的事件 & 观察者 （Observer）接收的事件 ---- 2. 类型 RxJava2中，过滤操作符的类型包括： ?...'io.reactivex.rxjava2:rxjava:2.0.7' // 注：RxJava2 与 RxJava1 不能共存，即依赖不能同时存在 } 3.1 根据 指定条件 过滤事件 需求场景...对应操作符使用 throttleFirst（）/ throttleLast（） 作用 在某段时间内，只发送该段时间内第1次事件 / 最后1次事件 如，1段时间内连续点击按钮，但只执行第1次的点击操作...总结 下面，我将用一张图总结 RxJava2 中常用的条件 / 布尔操作符 ?

    1.1K10

    Android：这是一份全面 & 详细的RxJava学习攻略

    具体请看文章： Carson带你学RxJava：这是一篇清晰易懂的Rxjava入门教程 Carson带你学RxJava：这是一份面向初学者的RxJava使用指南 Carson带你学RxJava：RxJava2.0...原理解析 在初步了解RxJava后，我们需要深入了解RxJava的原理，具体请看文章： Carson带你学RxJava：图文解析带你快速了解RxJava原理 Carson带你学RxJava：手把手带你源码分析...带你学RxJava：变换操作符 Carson带你学RxJava：条件/布尔操作符 4....实战（应用场景） 在介绍完 RxJava 的具体使用后，我将为大家介绍RxJava的应用场景 并以 案例教学 的形式 详解常见开发应用场景实现 结合常用相关框架如Retrofit 、RxBinding.../布尔操作符 应用 Carson带你学Android：什么时候应该使用Rxjava？

    96310

    Carson带你学Android：什么时候应该使用Rxjava？(开发场景汇总)

    今天，我将为大家带来 Rxjava的的基本使用 & 实际应用案例教学，即常见开发应用场景实现 ，并结合常用相关框架如Retrofit等，希望大家会喜欢。...实际开发应用场景 RxJava的实际开发应用场景 与 其对应的操作符息息相关 常见的RxJava实际开发应用场景有如下： 下面，我将对每个实际开发应用场景进行实例讲解教学 下面实例皆结合常用框架如Retrofit...RxJava 实际应用讲解：网络请求出错重连（结合Retrofit） 3.4 网络请求嵌套回调 背景 需要进行嵌套网络请求：即在第1个网络请求成功后，继续再进行一次网络请求 如 先进行 用户注册 的网络请求...实际应用讲解：功能防抖 3.10 联想搜索优化 需求场景 功能说明 具体实现 Android RxJava 实际应用讲解：联想搜索优化 3.11 控制被观察者发送事件 & 观察者接收事件速度...冲突 被观察者 发送事件速度太快，而观察者 来不及接收所有事件，从而导致观察者无法及时响应 / 处理所有发送过来事件的问题，最终导致缓存区溢出、事件丢失 & OOM 如，点击按钮事件：连续过快的点击按钮

    96820

    Android RxJava实际应用案例讲解：使用RxJava的最佳开发场景

    并结合常用相关框架如Retrofit等，希望大家会喜欢。...实际开发应用场景 RxJava的实际开发应用场景 与 其对应的操作符息息相关 常见的RxJava实际开发应用场景有如下： 下面，我将对每个实际开发应用场景进行实例讲解教学 下面实例皆结合常用框架如...RxJava 实际应用讲解：网络请求出错重连（结合Retrofit） 3.4 网络请求嵌套回调 背景 需要进行嵌套网络请求：即在第1个网络请求成功后，继续再进行一次网络请求 如 先进行 用户注册...RxJava 实际应用讲解：功能防抖 3.10 联想搜索优化 需求场景 功能说明 具体实现 Android RxJava 实际应用讲解：联想搜索优化 3.11 控制被观察者发送事件 & 观察者接收事件速度...冲突 被观察者 发送事件速度太快，而观察者 来不及接收所有事件，从而导致观察者无法及时响应 / 处理所有发送过来事件的问题，最终导致缓存区溢出、事件丢失 & OOM 如，点击按钮事件：连续过快的点击按钮

    1.4K50

    【RxJava】RxJava 基本用法 ( 引入 RxJava 依赖 | 定义 Observer 观察者 | 定义 Observable 被观察者 | 被观察者订阅观察者 )

    一、RxJava 基本用法 本章节涉及到的 RxJava 组成要素 : Observable（被观察者）： Observable 是一个 可以发送消息的数据源 , 可以同时发送若干消息 , 消息的格式可以通过泛型进行定义...1、引入 RxJava 依赖 Gradle 项目中 , 在 build.gradle 构建脚本中 , 添加如下依赖 ; dependencies { implementation 'io.reactivex.rxjava2...:rxjava:2.2.21' } rxjava3 依赖 : dependencies { implementation 'io.reactivex.rxjava3:rxjava:3.0.0' } Maven...项目中 , 在 pom.xml 中添加如下依赖 ; io.reactivex.rxjava2 rxjava...Observer 观察者 是 操作的核心 , 定义在需要进行具体操作的位置 , 执行具体的 异步操作 或 事件 ; 如 : 在 UI 界面中 , 点击按钮 , 查询远程数据库服务器中的数据 , 查询完毕后更新

    61320

    Rxjava源码解析笔记 | 创建Observable 与 ObserverSubscriber 以及之间订阅实现的源码分析

    简单回顾 如果抛开Rxjava的操作符以及其线程控制的话，Rxjava的最基本使用是比较简单的 第一步，创建被观察者Observable； 第二步，创建观察者Observer/Subscriber...； 第三步，subscribe； 三个关键对象和一个核心方法 三个关键对象 Observable（被观察者） OnSubscribe 此对象是Observable内部的对象， 可以对等地理解成是观察者模式中...， 被观察者用来通知观察者的notifyObservers()方法； Subscriber（观察者） 一个核心方法 subscribe() 订阅方法， 完成观察者和被观察者之间的订阅； Rxjava...这里可以看到如果传给subscribe()的对象是Observer， 则会在源码Rxjava的源码中首先被转换成Subscriber， 之后再进行后续操作； 也即应证了之前所说的Rxjava内部...onError()、onNext()等方法； 它就是对subscriber类做了一个包装； 注意onCompleted() 或者onError()方法被执行的时候， 就不会再执行onNext()（注意布尔变量

    1.6K30

    Rxjava源码解析笔记 | Rxjava基本用法

    Rxjava四要素 被观察者 在Rxjava当中， 决定什么时候触发事件， 决定触发什么样的事件； 观察者 决定事件触发的时候将产生什么样的行为； 类似于传统观察者模式， 观察者会随着被观察者的状态变化而发生相应的操作...：客户端从服务端获取到最新的数据时， 需要通知客户端本身相关模块进行更新（如UI变换显示等）； 这其实便是一种响应式编程—— 客户端根据服务端的变化做出相应； 生活中的例子 天气冷了我们就要多穿件衣服.../改变； 而在Rxjava中，框架给出了三个方法； 其中onCompleted()和onError()两个方法就是对传统观察者模式做出的改变/区别， 而onNext()其实就是传统观察者模式当中的...Observable是用过链式调用来执行的； 为的是让后面的操作符、线程控制等能够跟流式OPI来完善， 而不是其他方式如观察者去订阅被观察者（非链式）—— 这样从意思上容易理解，但在API调用上很不方便...对传统观察者设计模式的拓展和改进； 实际情况当中，其实它还包括了很多操作符， 以及Rxjava最核心的线程控制调度， 这两部分是Rxjava的核心.

    69220

    锦囊篇｜一文摸懂RxJava

    这个版本中，更新了一下的内容： （1）包结构变化RxJava 3 components are located under the io.reactivex.rxjava3 package (RxJava...那RxJava同样的是存在这样的问题的，处理速度一定，但是被观察者的数据量过大，我们该如何去进行处理呢？这就引出了背压的概念。...在Android的开发过程中我们一直已经都有一个强烈的概念叫做耗时任务不要放在UI线程来运作，那我们的RxJava呢？回到我们上述的代码中，做一个实验进行一下观察。...c2a7c03da16d 功能操作符：https://www.jianshu.com/p/b0c3669affdb 过滤操作符：https://www.jianshu.com/p/c3a930a03855 条件/布尔操作符...我的被观察者有数据了，但是我们的观察者该如何知道？ 先来看一下如何进行使用，我们应该在IO线程中进行订阅，在UI线程中进行观察。

    81920

    Android RxJava应用：优雅实现网络请求嵌套回调

    今天，我将为大家带来 Rxjava创建操作符的实际开发需求场景：网络请求嵌套回调 需求 ，并结合Retrofit 与RxJava 实现，希望大家会喜欢。...需求场景 1.1 背景 需要进行嵌套网络请求：即在第1个网络请求成功后，继续再进行一次网络请求 如 先进行 用户注册 的网络请求, 待注册成功后回再继续发送 用户登录 的网络请求 1.2 冲突 嵌套实现网络请求较为复杂...'io.reactivex.rxjava2:rxjava:2.0.1' compile 'io.reactivex.rxjava2:rxandroid:2.0.1' // Android 支持 Retrofit...是对初始被观察者作变换，所以对于旧被观察者，它是新观察者，所以通过observeOn切换线程...// 但对于初始观察者，它则是新的被观察者 .flatMap(new Function<Translation1, ObservableSource<Translation2

    1.2K20

    Android RxJava操作符详解 系列：组合 合并操作符

    如果还不了解 RxJava，请看文章：Android：这是一篇 清晰 & 易懂的Rxjava 入门教程 RxJava如此受欢迎的原因，在于其提供了丰富 & 功能强大的操作符，几乎能完成所有的功能需求...作用 组合 多个被观察者（`Observable`） & 合并需要发送的事件 ---- 2. 类型 RxJava 2 中，常见的组合 / 合并操作符 主要有： ?...:rxandroid:2.0.1' compile 'io.reactivex.rxjava2:rxjava:2.0.7' // 注：RxJava2 与 RxJava1 不能共存...4.2 合并数据源 & 同时展示 即，数据源 来自不同地方（如网络 + 本地），需要从不同的地方获取数据 & 同时展示 具体请看文章：Android RxJava 实际应用讲解：合并数据源 4.3 联合判断...即，同时对多个事件进行联合判断 如，填写表单时，需要表单里所有信息（姓名、年龄、职业等）都被填写后，才允许点击 “提交” 按钮 具体请看文章：Android RxJava 实际应用讲解：联合判断

    2.2K30

    Carson带你学Android：RxJava组合合并操作符

    今天，我将为大家详细介绍RxJava操作符中最常用的 组合 / 合并操作符，并附带 Retrofit 结合 RxJava的实例Demo教学，希望你们会喜欢。...作用 组合 多个被观察者（Observable） & 合并需要发送的事件 2. 类型 RxJava 2 中，常见的组合 / 合并操作符 主要有： 下面，我将对每个操作符进行详细讲解 3....:rxandroid:2.0.1' compile 'io.reactivex.rxjava2:rxjava:2.0.7' // 注：RxJava2 与 RxJava1 不能共存...4.2 合并数据源 & 同时展示 即，数据源 来自不同地方（如网络 + 本地），需要从不同的地方获取数据 & 同时展示 具体请看文章：Android RxJava 实际应用讲解：合并数据源 4.3 联合判断...即，同时对多个事件进行联合判断 如，填写表单时，需要表单里所有信息（姓名、年龄、职业等）都被填写后，才允许点击 “提交” 按钮 具体请看文章：Android RxJava 实际应用讲解：联合判断 5

    81710
    点击加载更多

    扫码

    添加站长 进交流群

    领取专属 10元无门槛券

    手把手带您无忧上云

    扫码加入开发者社群

    相关资讯

    热门标签

    更多标签

    活动推荐

      运营活动

      活动名称
      广告关闭

      腾讯云开发者

      扫码关注腾讯云开发者

      扫码关注腾讯云开发者

      领取腾讯云代金券

      热门产品

      热门推荐

      更多推荐

      Copyright © 2013 - 2025 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有

      深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 深公网安备号 44030502008569

      腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号 | 京公网安备号11010802020287

      领券