- 综合排序
- 最热优先
- 最新优先
- 来自专栏小白鼠
RxJava
Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins"); // 调用ObservableCreate的subscribeActual
1.4K30发布于 2019-01-28 - 来自专栏韩曙亮的移动开发专栏
【RxJava】RxJava 简介 ( RxJava 概念 | RxJava 组成 - 被观察者 观察者 订阅 操作符 | RxJava 适用场景 )
一、RxJava 简介 1、RxJava 概念 RxJava 框架 是一个 异步编程函数库 , 包含了如下要素 : 观察者模式 迭代器模式 函数式编程 RxJava 框架应用场景 : 异步操作 事件流 2、RxJava 组成 - 被观察者 / 观察者 / 订阅 / 操作符 RxJava 组成要素 : Observable（被观察者）： Observable 是一个 可以发送消息的数据源 , 可以同时发送若干消息 可以进行消息的 过滤、变换、合并、组合等操作 ; 3、RxJava 适用场景 RxJava 通过 组合调用 / 链式调用 被观察者 / 观察者 / 订阅 / 操作符 要素 ; RxJava 可以简化 RxJava 还支持 线程切换 / 并发处理 / 错误处理 ，利于处理各种 并发 和 异步 操作。 RxJava 异步编程库，蕴含了 响应式编程 思想 ，提供了 简洁、灵活和可组合 的方式 来 处理 异步任务 和 事件流。
1.2K30编辑于 2023-10-11 - 来自专栏增长技术
Android RxJava
RxJava Operators By Category Creating Observables 创建 Operators that originate new Observables.
74320发布于 2018-09-06 - 来自专栏青蛙要fly的专栏
RxJava小考题 -- Rxjava源码分析(一)
前言： 现在面试很多都会问RxJava的源码，直接讲RxJava的源码，估计大家都不太会看下去，我们先看个小考题，然后再去看相关的源码。 isDisposed(); i++) { T value = a[i]; /*我们知道在RxJava 1的时候我们发送一个null值是可以的 ， 但是RxJava2就不行了，因为做了一个判空操作。 而情形二其实不是考验RxJava的源码基础，而是考验 Java基础。 具体可以参考这篇：Java值传递以及引用的传递、数组的传递 结语： 所以本章我们更多地看了Rxjava的Observable生成及Observer订阅时候的部分源码及Java值传递等相关知识。
82220发布于 2018-08-29 - 来自专栏Flutter入门到实战
RxJava 详解
有人说『RxJava 真是太好用了』，有人说『RxJava 真是太难用了』，另外更多的人表示：我真的百度了也谷歌了，但我还是想问： RxJava 到底是什么？ 鉴于 RxJava 目前这种既火爆又神秘的现状，而我又在一年的使用过程中对 RxJava 有了一些理解，我决定写下这篇文章来对 RxJava 做一个相对详细的、针对 Android 开发者的介绍。 RxJava 提供了对事件序列进行变换的支持，这是它的核心功能之一，也是大多数人说『RxJava 真是太好用了』的最大原因。 不过 RxJava 的变换远不止这样，它不仅可以针对事件对象，还可以针对整个事件队列，这使得 RxJava 变得非常灵活。 因此，我写了这篇《给 Android 开发者的 RxJava 详解》，希望能给始终搞不明白什么是 RxJava 的人一些入门的指引，或者能让正在使用 RxJava 但仍然心存疑惑的人看到一些更深入的解析
2.2K10发布于 2018-09-03 - 来自专栏李蔚蓬的专栏
Rxjava源码解析笔记 | Rxjava基本用法
Rxjava四要素 被观察者 在Rxjava当中， 决定什么时候触发事件， 决定触发什么样的事件； 观察者 决定事件触发的时候将产生什么样的行为； 类似于传统观察者模式， 观察者会随着被观察者的状态变化而发生相应的操作 其中，其实Subscriber就是我们的观察者； 后面的Rxjava源码阅读中， 我们会发现Observer在源码中也会被转换成Subscriber来进行相应的处理， 所有才说其实Subscriber 第二步， 创建观察者Observer/Subscriber，即第二个要素， 1.在传统的观察者模式当中，观察者只有一个update()方法， 在其中根据被观察者的状态变化而做出反应/改变； 而在Rxjava 的一种简单的使用， 主要是理解一下Rxjava对传统观察者设计模式的拓展和改进； 实际情况当中，其实它还包括了很多操作符， 以及Rxjava最核心的线程控制调度， 这两部分是Rxjava的核心 package com.example.jiajiemu.a11.rxjava; import rx.Observable; import rx.Observer; import rx.Subscriber
91820发布于 2019-06-05 - 来自专栏allsmallpi博客
rxjava---demo
io.reactivex.rxjava3 rxjava 3.0.3
92220发布于 2021-02-25 - 来自专栏Java与Android技术栈
RxJava 之 TestScheduler
在 RxJava2.x 中，原先RxJava1.x的Schedulers.test()被去掉了，想要获得TestScheduler对象可以通过直接new TestScheduler()的方式来实现。 p=979 https://github.com/ReactiveX/RxJava/wiki/What's-different-in-2.0
96320发布于 2018-08-24 - 来自专栏编程
RxJava系列一
本章节中部分概念摘自《RxJava Essentials》一书 RxJava的来历 Rx是微软.Net的一个响应式扩展，Rx借助可观测的序列提供一种简单的方式来创建异步的，基于事件驱动的程序。 并于13年二月份正式向外展示了RxJava。 从语义的角度来看，RxJava就是.NET Rx。从语法的角度来看，Netflix考虑到了对应每个Rx方法,保留了Java代码规范和基本的模式。 什么是RxJava 那么到底什么是RxJava呢？我对它的定义是：RxJava本质上是一个异步操作库，是一个能让你用极其简洁的逻辑去处理繁琐复杂任务的异步事件库。 RxJava好在哪 Android平台上为已经开发者提供了AsyncTask,Handler等用来做异步操作的类库，那我们为什么还要选择RxJava呢？答案是简洁！ (此例子思路来源于扔物线的给Android开发者的RxJava详解一文) 使用RxJava的写法是这样的： 从上面这段代码我们可以看到：虽然代码量看起来变复杂了，但是RxJava的实现是一条链式调用，没有任何的嵌套
1.1K100发布于 2018-01-15 - 来自专栏BaronTalk
RxJava系列六(从微观角度解读RxJava源码)
前言 通过前面五个篇幅的介绍，相信大家对RxJava的基本使用以及操作符应该有了一定的认识。但是知其然还要知其所以然；所以从这一章开始我们聊聊源码，分析RxJava的实现原理。 本文我们主要从三个方面来分析RxJava的实现： RxJava基本流程分析 操作符原理分析 线程调度原理分析 本章节基于RxJava1.1.9版本的源码 一、RxJava执行流程分析 在RxJava系列 super String> subscriber) { subscriber.onNext("Hello RxJava!") （由于对RxJavaHooks的理解并不影响我们对RxJava执行流程的分析，因此在这里我们不做进一步的探讨。 总结 这一章以执行流程、操作符实现以及线程调度三个方面为切入点剖析了RxJava源码。下一章将站在更宏观的角度来分析整个RxJava的框架结构、设计思想等等。
1.8K70发布于 2018-04-13 - 来自专栏全栈程序员必看
Android MVP+RxJava+Retrofit (3) MVP+RxJava+Retrofit
前面说了RxJava 与Retrofit的基本用法,但是没用做优化的处理.本篇先做一个优化处理,然后再结合前面的MVP 设计模式,把这些知识贯穿到一个Demo 之中,方便大家理解. }); 接下来我要说的 就是MVP 设计模式 下 请求网络获取商品列表并展示的过程了 这个是效果图 就是请求网络并获取商品列表的功能 根据之前 MVP 设计模式，外加RxJava .client(client) .baseUrl(Constant.IP) .addCallAdapterFactory(RxJava2CallAdapterFactory.create
1.5K20发布于 2021-04-07 - 来自专栏移动开发
RxJava使用总结
1.RxJava在android中想要使用AndroidSchedulers.mainThread()这个线程,需要在你的gradle文件添加下面这个依赖 compile 'io.reactivex :rxandroid:0.23.0' 2.RxLifecycle(GitHub地址)是一个方便我们在安卓中解除Rxjava中订阅,以防内存泄露问题的开源库.有几种写法,这里要注意根据你所使用的方式,添加合适的依赖 compile 'com.trello:rxlifecycle-components:0.4.0' compile 'com.trello:rxlifecycle-navi:0.4.0' 这里附上我用RxJava
95520发布于 2018-10-18 - 来自专栏码农沉思录
RxJava源码剖析
作者：aprz512 原文：http://lyldalek.cn/2018/01/06/RxJava-%E6%BA%90%E7%A0%81%E5%88%86%E6%9E%901/ 前言 本篇的文章是基于 Rxjava 2.1.2。 从下面的一段代码中，我们从源码的角度分析 RxJava 的实现原理： ObservableOnSubscribe<Integer> oos = new ObservableOnSubscribe<Integer AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.computation()) .subscribe(o); 分析源码之前，我们先定义一下名词，RxJava 如此，RxJava 的一个流程就理清楚了。这货的流程和 OkHttp 怎么有点像，只是稍微有点不一样。
1.1K10发布于 2019-05-04 - 来自专栏Java与Android技术栈
RxJava 并行操作
上一篇文章RxJava 线程模型分析详细介绍了RxJava的线程模型，被观察者(Observable、Flowable...)发射的数据流可以经历各种线程切换，但是数据流的各个元素之间不会产生并行执行的效果
1.7K10发布于 2018-08-24 - 来自专栏三流程序员的挣扎
RxJava Flowable Processor
在异步调用时，RxJava 中有个缓存池，用来缓存消费者处理不了暂时缓存下来的数据，缓存池的默认大小为 128，即只能缓存 128 个事件。 backpress.PNG BUFFER 就是把 RxJava 中默认的只能存 128 个事件的缓存池换成一个大的缓存池，支持存很多很多的数据。 Subject 不支持背压，是 RxJava 1.x 继承过来的，Processor 继承 FlowableProcessor，支持背压。
2.4K20发布于 2018-09-11 - 来自专栏编程
RxJava系列五
程序输出： 通过转换操作符、过滤操作符、组合操作符三个篇幅将RxJava主要的操作符也介绍的七七八八了。更多操作符的介绍建议大家去查阅官方文档，并自己动手实践一下。
94360发布于 2018-01-10 - 来自专栏github@hornhuang
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.4K20发布于 2021-09-24 - 来自专栏叽叽西
RxJava2
在Android开发中使用函数响应式编程的主要有两大框架： 一个是 RxJava，另一个是 Goodle 推出的 Agera。本章我们来学习 RxJava。 filepath=io/reactivex/rxjava2/rxjava/2.2.3/rxjava-2.2.3.jar // create a flowable Flowable 参考 ReactiveX/RxJava: RxJava – Reactive Extensions for the JVM – a library for composing asynchronous https://github.com/ReactiveX/RxJava 这可能是最好的RxJava 2.x 教程（完结版） - 简书 https://www.jianshu.com/p/0cd258eecf60 RxJava2 系列 (1)：一篇的比较全面的 RxJava2 方法总结 - 掘金 https://juejin.im/post/5b72f76551882561354462dd 给 Android
96010编辑于 2022-05-17 - 来自专栏Android理论
RxJava源码剖析
前言 本篇的文章是基于Rxjava 2.1.2。 从下面的一段代码中，我们从源码的角度分析 RxJava 的实现原理： ObservableOnSubscribe<Integer> oos = new ObservableOnSubscribe<Integer AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.computation()) .subscribe(o); 分析源码之前，我们先定义一下名词，RxJava 如此，RxJava 的一个流程就理清楚了。这货的流程和 OkHttp 怎么有点像，只是稍微有点不一样。 相关视频 【Android进阶】Rxjava与low响应式编程
78550编辑于 2021-12-08 - 来自专栏安卓圈
RxJava简析
rxjava文档地址https://mcxiaoke.gitbooks.io/rxdocs/content/ 这个是中文版的 android studio 添加依赖 implementation ' io.reactivex.rxjava3:rxjava:3.0.4' 首先，打印helloworld： public void hello(String args){ Flowable.fromArray System.out.println(integer); } }); 先过滤再循环输出 第6个组合操作符and/then/when implementation 'io.reactivex:rxjava-joins
92310发布于 2020-11-25
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号