安卓分区
谷粒商城
数据标注
软件工程
二维码
ICU
gerapy
产品经理培训
PIXIjs
opengl
图像视图
canva可画
Security
异常
构造函数
免费实用
POP
Landsat
Linux常用命令
树组件禁用父节点
rxjava
2024/4/11 22:29:01
RxJava与网络相关的操作符（range/defer/retry/repeat/timer/delay/interval/BehaviorSubject/zip）
工欲善其事必先利其器。不多废话直接看重点。
操作符range
range操作符的作用Range操作符根据出入的初始值n和数目m发射一系列大于等于n的m个值。
public class MainActivity extends AppCompatActivity { private Button btn; Override protected void onCreate(Bundle …
巧用RxJava解决网络连接失败问题及Token失效自动获取问题
网络连接失败的处理
看过最前面那篇文章的应该很清楚retryWhen()是什么了。 我再来总结一下，retryWhen()的直面意思就是：发生错误了，接下来该做什么。 retryWhen()是RxJava的一种错误处理机制，当遇到错误时，将错误传…
【Android】RxJava系列01-基本概述和基本用法
少年啊，要永远相信美好的事情即将发生 【Android】RxJava系列01-基本概述和基本用法 1.RxJava的概述2.RxJava的作用3.观察者和被观察者4.背压5.RxJava的基本用法步骤一，创建Observer（观察者）步骤二，创建Observable&…
将 RxJava 的 Observable 转换为 Reactor 的 Flux流
如果您想将 RxJava 的 Observable 转换为 Reactor 的 Flux，可以使用 Reactor Adapter 库来实现这一转换。这个库提供了一些静态方法来将 RxJava 类型转换为 Reactor 类型。
以下是一个示例代码，演示了如何将 RxJava 的 Observable 转换为 Reactor 的 Flux：
import reactor…
Rxjava转换操作符
文章目录1 Map2 FlatMap3 GroupBy4 Buffer5 Scan参考：https://www.jianshu.com/p/904c14d253ba
作用 ： 将事件类型转换成我们所要的结果类型。
MapFlatMapGroupByBufferScanWindow
以下代码在单元测试的ExampleUnitTest中运行。
1 Map
对 被观察者发…
Rxjava 合并操作符
文章目录1 startWith2 concat3 merge4 concatDelayError5 zip组合 多个被观察者（Observable） & 合并需要发送的事件
1 startWith
在一个被观察者发送事件前，追加发送一些数据 / 一个新的被观察者 Testpublic void testStartWith() thro…
Rxjava 错误处理操作符
文章目录1 onErrorReturn2 onExceptionResumeNext3 onErrorResumeNext4 retry1 onErrorReturn
发生 onError 时返回一个特定的值，然后 onComplete。 private void func() {// 适用于 可能会出现崩溃 但是结果不影响程序的运行。 比如说 访问数组时 …
【Rxjava详解】(二) 操作符的妙用
文章目录 接口变化操作符mapflatmapdebouncethrottleFirst()takeconcat RxJava 是一个基于
观察者模式的异步编程库，它提供了丰富的操作符来处理和转换数据流。
操作符是 RxJava 的核心组成部分，它们提供了一种灵活、可组合的方式来处理数据流…
Rxjava源码分析实践（七）【实践环节：线程切换功能实现】
上一节，我们已经实现了Rxjava基本的map事件变换功能，而且对于其中的原理进行了回顾。这节，我们一起来实现一下线程切换的功能。 RxJavaStudy Demo Github源码
1.前言
实现线程切换功能之前，通过一个实例，我们先看一下rxjava线程切换功能的使用代码。 **需求：**我们自己…
Airtable、pyairtable
文章目录 一、关于 AirtableAirtable 公司历史诞生发展 产品方向产品层级国内模仿者竞争对手关于 API Key价格 二、关于 pyairtable安装快速使用 一、关于 Airtable
官网：https://www.airtable.comgithub : https://github.com/AirtableAirtable AI ： h…
积木报表 JimuReport v1.6.2-GA版本发布—高危SQL漏洞安全加固版本
项目介绍 一款免费的数据可视化报表，含报表和大屏设计，像搭建积木一样在线设计报表！功能涵盖，数据报表、打印设计、图表报表、大屏设计等！ Web 版报表设计器，类似于excel操作风格，通过拖拽完成报…
Rtrofit+Rxjava网络请求封装
好几年前封装的框架一直没上传，趁现在升级写下。 简介Retrofit是android的网络请求库，是一个RESTful的HTTP网络请求框架的封装（基于okhttp）。它内部网络请求的工作，本质上是通过OkHttp完成，而Retrofit仅负责…
构建第一个ArkTS应用（FA模型）
创建ArkTS工程
若首次打开DevEco Studio，请点击Create Project创建工程。如果已经打开了一个工程，请在菜单栏选择File > New > Create Project来创建一个新工程。选择Application应用开发（本文以应用开发为例，Atomic Servi…
rxjava+retrofit+okhttp+mvp 简单实践
好久没写博客了，汗，平时喜欢看博客，却不喜欢写博客，这样不行的，惭愧！
今年进了一家新公司，老大说了，先熟悉代码，等新的UI出来后，重构。所以，这些…
【漏洞复现】Jeecg-Boot SQL注入漏洞(CVE-2023-34659)
漏洞描述
jeecgBoot是一款基于BPM的低代码平台！前后端分离架构 SpringBoot 2.x，SpringCloud，Ant Design&Vue，Mybatis-plus，Shiro，JWT，支持微服务。强大的代码生成器让前后端代码一键生成，实现低代码开发！JeecgBoot引领新低代码开发模式 OnlineCoding-> 代码生…
HarmonyOS Developer——鸿蒙【构建第一个JS应用（FA模型）】
创建JS工程 JS工程目录结构 构建第一个页面 构建第二个页面 实现页面间的跳转 使用真机运行应用 说明 为确保运行效果，本文以使用DevEco Studio 3.1 Release版本为例，点击此处获取下载链接。 创建JS工程 若首次打开DevEco Studio，请点击…
Rxjava 过滤操作符
文章目录1 filter2 take3 distinct4 elementAt参考：https://www.jianshu.com/p/c3a930a03855
作用 ：对多个事件进行过滤 filter take distinct elementAt （指定）
1 filter
例如：一堆商品中选出已经过期的商品 其…
android--RxJava源码详解
其实所有的节日都不是为了礼物和红包而生，而是为了提醒我们，不要忘记爱与被爱，生活需要仪式感，而你需要的是在乎和关爱 目录 前言 一，Hook点 二，RXJava的观察者模式 三，Map操作符原理 前言
关于…
简单手写Rxjava
文章目录1 Rxjava的使用流程2 手写1 Rxjava的使用流程 //服务员ObservableOnSubscribe<String> observableOnSubscribe new ObservableOnSubscribe<String>() {Overridepublic void subscribe(ObservableEmitter<String> emitter) throws Exception {}};//顾…
【Rxjava详解】(六)操作符执行原理
解析一些常见操作符的执行原理，它们都会交给Observablexxx去执行，然后在进行自己的处理。
map()
public final <R> Observable<R> map(Function<? super T, ? extends R> mapper) {ObjectHelper.requireNonNull(mapper, "map…
深入浅出RxJava三--响应式的好处
原文地址为：
深入浅出RxJava三--响应式的好处原文链接 在第一篇中，我介绍了RxJava的基础知识。第二篇中，我向你展示了操作符的强大。但是你可能仍然没被说服。这篇里面，我讲向你展示RxJava的其他的一些好处，相信这篇足…
RxJava使用场景小结
转载自：http://blog.csdn.net/lzyzsd/article/details/50120801 取数据先检查缓存的场景 取数据，首先检查内存是否有缓存 然后检查文件缓存中是否有 最后才从网络中取 前面任何一个条件满足，就不会执行后面的 final Observable<String&…
一起Talk Android吧（第五百三十六回：RxJava中的事件转换）
文章目录概念介绍使用方法示例代码各位看官们大家好，上一回中咱们说的例子是"RxJava中的被观察者",本章回中介绍的例子是"
RxJava的事件转换"。闲话休提，言归正转，让我们一起Talk Android吧！概念介绍
我们在…
从零实现一套低代码（保姆级教程） --- 【9】实现Form组件并串通容器组件机制
摘要
目前，我们的低代码项目，已经把基本的架子搭好了。后续我们会陆续添加一些其他的功能。
如果你是第一次看到这一篇文章， 建议先看一下第一节内容： 从零实现一套低代码（保姆级教程） — 【1】初始化项目…
RxJava Subject
目录 AsyncSubjectBehaviorSubjectPublishSubjectReplaySubjectSerializedSubjectUnicastSubject 在Rxjava中， Subject可以同时表示Observer和Observable, 允许从单个源到多个子观察者multiple child Observers。 除了 onSubscribe(io.reactivex.disposables.Dispos…
Android MVP-使用RxJava和注解消除接口回调
在Android MVP 构建一个简单的MVP中实现了一个简单MVP框架，在使用Presenter中通过接口回调的方式获取Model中的数据，如下图： 这里通过Rxjava和注解来消除接口回调。
添加rxjava依赖： //rxjavaimplementation "io.reactivex.…
Rxjava 条件操作符
文章目录1 all2 contains3 any4 isEmpty5 defaultIfEmpty6 skipWhile作用：从事件中是不是 满足 得 到结果（ 一个）1 all
2 contains
3 any
4 isEmpty
5 defaultIfEmpty
6 skipWhile
1 all
判断发送的每项数据是否都满足 设置的函数条件…
Android中的RxJava入门及常用操作符
文章目录 1.定义2.作用3.特点4.使用4.1创建被观察者（Observable）4.2创建观察者（Observer）4.3订阅（Subscribe）4.4Dispose 5.操作符5.1操作符类型5.2just操作符5.2链式调用5.3 fromArray操作符5.4 fromIterab…
【低代码开发】：低代码开发助力应用创新
低代码开发：加速应用开发的未来趋势 引言什么是低代码以及功能特点？什么是低代码开发？低代码平台的特点和功能低代码平台的应用场景和优势低代码的优点低代码的缺点低代码平台项目开发流程选择和实施低代码平台 低代码未来的发展趋势低代码平…
Android Studio实现文艺阅读App
项目目录 一、系统概述二、系统特点三、开发环境四、运行演示五、源码获取 一、系统概述
本次带来的文艺阅读App可以提供高质量的原创文学作品。用户可以App中找到各种类型的文学作品，包括小说、散文、诗歌等，由来自不同领域的作家所创作。此外…
一起Talk Android吧（第五百三十四回：RxJava中的观察者）
文章目录概念介绍使用方法示例代码各位看官们大家好，上一回中咱们说的例子是"RxJava中断事件流",本章回中介绍的例子是"
RxJava的观察者"。闲话休提，言归正转，让我们一起Talk Android吧！概念介绍
我们在前面…
安卓使用okhttp3+retrofit2+rxjava实现网络通信
前言：最近做一个安卓应用，实现安卓端从服务器端获取电影列表的功能，于是自己搭建了asp.net服务端并实现安卓代码，之前就用这种方式实现安卓和服务器通信，但是之前后端使用java编写，通过这个应用才知道&…
Android Retrofit+Rxjava实现网络请求（Retrofit如何结合Rxjava）
RxjavaRetrofit实现网络请求前言操作添加依赖修改接口管理器修改接口访问运行结果前言
Retrofit和Rxjava单独使用的文章可以看本人写的这两篇，本文是在Retrofit网络请求框架这篇文章的项目上改动的。 Android Retrofit网络请求框架 Android RxJava3入门
操作
添加…
Android RxJava的使用
首语简介特点RxAndroid观察者模式四大要素扩展的观察者模式使用GitHub地址依赖Hello World操作符Creating Observables(创建 Observable)CreateJustFromDeferEmpty/Never/ThrowIntervalRangeRepeatStartTimerTransforming Observables(转换 Observable)MapFlatMapGroupByBuffer…
Android DataBinding 从入门到进阶，看这一篇就够
前言
DataBinding 是谷歌官方发布的一个框架，顾名思义即为数据绑定，是 MVVM 模式在 Android 上的一种实现，用于降低布局和逻辑的耦合性，使代码逻辑更加清晰。MVVM 相对于 MVP，其实就是将 Presenter 层替换成了 ViewMo…
【Android笔记81】Android之RxJava的介绍及其使用
这篇文章，主要介绍Android之RxJava及其使用。 目录
一、RxJava响应式编程
1.1、RxJava介绍
1.2、RxJava常用方法
（1）引入RxJava依赖
【webFlux】使用zip()或concatMap操作符处理两个表，基于条件修改两个表
要响应式地处理两个列表，并基于条件修改第一个列表的一个bean，并根据条件修改第二个列表中对应bean的属性，你可以使用RxJava的操作符来实现。
以下是一个示例代码，展示了如何响应式地处理两个列表并进行相应的修改操作：
Observable<List<Bean1>> list1Obser…
android--RxJava线程调度源码详解
从今天起关闭烦恼，开启赚钱模式，别去想那些乱七八糟的破事了，满脑子都是钱不好吗，肤浅又快乐！ 目录 前言 一，IO线程调度 二，安卓主线程调度 前言
学习线程调度的源码之前，我们需要先…
从零实现一套低代码（保姆级教程） --- 【11】实现Card卡片组件及属性样式配置
摘要
我们通过十个篇章，把组件列表，画布区，属性面板，样式面板，容器组件这五个主要模块实现出来了。
如果想继续添加组件，就按照之前的方式添加即可。对于数据录入这样的组件，或者一个按钮一个…
The exception was not handled due to missing onError handler in the subscribe() method call
The exception was not handled due to missing onError handler in the subscribe() method call. Further reading: https://github.com/ReactiveX/RxJava/wiki/Error-Handling | cn.leancloud.AVException 出现这个问题，是因为在使用Rxjava的时候，没有…
JeecgBoot jmreport/loadTableData RCE漏洞复现(CVE-2023-41544)
免责声明：文章来源互联网收集整理，请勿利用文章内的相关技术从事非法测试，由于传播、利用此文所提供的信息或者工具而造成的任何直接或者间接的后果及损失，均由使用者本人负责，所产生的一切不良后果与文章作者无关。该…
RxJava之Hello, World
RxJava 简介
RxJava 是一个基于事件流和异步编程的库，它可以用于编写响应式、异步和基于事件驱动的程序。它提供了一套丰富的操作符，可以方便地处理数据流的变换、过滤和组合。
RxJava 基于观察者模式和迭代器模式，引入了可观察序列&#x…
【Android】MVC与MVP的区别，MVP网络请求实践
一、MVC模式
目录
一、MVC模式二、MVP模式 1、MVP的简单应用 1.1 导入相关依赖包并设置权限1.2 实现Model1.2 实现Presenter1.3 实现View1.4分析项目结构和绑定过程1.5效果展示 2、MVP结合RxJava
一、MVC模式
MVC（Model(模型)——View(视图)——Controller(控制…
android--RXJava+Retrofit封装使用
在欲望的城市里，你就是我最后的信仰。 目录 前言 一，方法封装 二，okhttpretrofitrxjava 实现网络请求 前言
关于RXJava的基本使用，请参考 文章android--RXJava详细使用篇-CSDN博客
下面我们讲一下RXJava在android中的相对比较…
安卓开发之Retrofit+RxJava的简单使用
介绍
Retrofit是封装了okHttprxJava的网络请求库，可以用来处理网络请求。
如果遇到比较复杂的情况，可以结合RxJava进行处理案例
基于我之前写的Retrofit基础用法的文章安卓开发之Retrofit2.0的使用里的例子，我们定义连接失败的话，…
RxJava2.0——入门教程
文章目录了解观察者模式RxJava2.0 基本使用RxJava2.0的异步和链式编程了解观察者模式
简单介绍一下，A和B两个，A是被观察者，B是观察者，B对A进行观察，B并不是需要时刻盯着A，而是A如果发生了变化，…
鸿蒙前端开发-构建第一个ArkTS应用（Stage模型）
创建ArkTS工程 若首次打开DevEco Studio，请点击Create Project创建工程。如果已经打开了一个工程，请在菜单栏选择File > New > Create Project来创建一个新工程。 选择Application应用开发（本文以应用开发为例，Atomic Serv…
【iVX】在百花齐放的低代码平台中独领风骚
💂作者简介： THUNDER王，一名热爱财税和SAP ABAP编程以及热爱分享的博主。目前于江西师范大学本科在读，同时任汉硕云（广东）科技有限公司ABAP开发顾问。在学习工作中，我通常使用偏后端的开发语言A…
Kotlin的数据流
LiveData 则是一种可观察的数据存储器类，与常规的可观察类不同，LiveData 具有生命周期感知能力，它遵循其他应用组件（如 Activity、Fragment 或 Service）的生命周期。这种感知能力可确保LiveData当数据源发生变化的时候…
基于鸿蒙OS开发一个前端应用
创建JS工程：做鸿蒙应用开发到底学习些啥？
若首次打开DevEco Studio，请点击Create Project创建工程。如果已经打开了一个工程，请在菜单栏选择File > New > Create Project来创建一个新工程。选择HarmonyOS模板库，…
Rxjava线程控制（切换 / 调度 ）
参考：https://www.jianshu.com/p/5225b2baaecd
为什么要进行RxJava线程控制（调度 / 切换）？ 在 RxJava模型中，被观察者 （Observable） / 观察者（Observer）的工作线程 创建…
一起Talk Android吧（第五百三十三：RxJava中断事件流）
文章目录概念介绍实现方法示例代码各位看官们大家好，上一回中咱们说的例子是"RxJava基本用法",本章回中介绍的例子是"
RxJava中断事件流"。闲话休提，言归正转，让我们一起Talk Android吧！概念介绍
我们在上一…
【精】给 Android 开发者的 RxJava 详解
出处：http://gank.io/post/560e15be2dca930e00da1083 前言 我从去年开始使用 RxJava ，到现在一年多了。今年加入了 Flipboard 后，看到 Flipboard 的 Android 项目也在使用 RxJava ，并且使用的场景越来越多 。而最近这几个月&#…
一起Talk Android吧（第五百三十八回：RxJava中的生命周期）
文章目录概念介绍使用方法示例代码综合使用各位看官们大家好，上一回中咱们说的例子是"RxJava中的timer",本章回中介绍的例子是"
RxJava中的生命周期"。闲话休提，言归正转，让我们一起Talk Android吧！概念介绍 …
Rxjava中的操作符学习笔记
1. Create
create 操作符应该是最常见的操作符了，主要用于产生一个 Obserable 被观察者对象 Observable.create(new ObservableOnSubscribe<Integer>() {Overridepublic void subscribe(NonNull ObservableEmitter<Integer> e) throws Exception {mRxO…
RxJava2详细版
RxJava2 实战系列文章(2017.08.27 ~ 2017.09.09) RxJava2 RxJava2 实战知识梳理(1) - 后台执行耗时操作，实时通知 UI 更新 RxJava2 实战知识梳理(2) - 计算一段时间内数据的平均值 RxJava2 实战知识梳理(3) - 优化搜索联想功能 RxJava2 实战知识梳理(4) - 结合 R…
给初学者的RxJava2.0教程
给初学者的RxJava2.0教程(一) 给初学者的RxJava2.0教程(二) 给初学者的RxJava2.0教程(三) 给初学者的RxJava2.0教程(四) 给初学者的RxJava2.0教程(五) 给初学者的RxJava2.0教程(六) 给初学者的RxJava2.0教程(七) 给初学者的RxJava2.0教程(八) 给初学者的RxJava2.0教程(九) 给初…
RxJava 2.0
RxJava的目的就是异步 Observable：在观察者模式中称为“被观察者”； Observer：观察者模式中的“观察者”，可接收Observable发送的数据； subscribe：订阅，观察者与被观察者，通过subscr…
Kotlin多平台响应式框架reaktive
Kotlin多平台响应式框架reaktive
Kotlin跨平台Reactive Extensions实现。
安装配置
这里有几个已经发布到 Maven Central 的模块：
reaktive：Reaktive 的主要库（多平台）reaktive-annotations：注解集合（…
Rxjava 创建操作符
文章目录1 create1.1 分步骤实现1.2 基于事件流的链式调用方式2 just3 fromArray4 emptyhttps://github.com/ReactiveX/Rxjava
https://github.com/ReactiveX/RxAndroid
参考： https://www.jianshu.com/p/e19f8ed863b1
添加依赖库： implementation io…
构建第一个JS应用（FA模型）
创建JS工程
若首次打开DevEco Studio，请点击Create Project创建工程。如果已经打开了一个工程，请在菜单栏选择File > New > Create Project来创建一个新工程。选择Application应用开发（本文以应用开发为例，Atomic Service对…
01_RxJava操作符示例代码
抽时间研究了下RxJava，因为网络博文讲述描述性文字较多，示例较少，很多时候不知道怎么开始入手学习RxJava，因此在此发文让想入门的看了博文之后实操一下，步骤很简单： 1.在网上下载一个RxJava的jar包…
提升协作效率：钉钉流程与低代码平台的无缝对接
摘要：本文由葡萄城技术团队原创并首发。转载请注明出处：葡萄城官网，葡萄城为开发者提供专业的开发工具、解决方案和服务，赋能开发者。 前言
钉钉作为目前很多企业都在使用的移动办公平台，提供了很多常用的OA审批功能&…
Rxjava基本介绍
一,作用 RxJava的目的就是异步。RxJava的特点就是可以非常简便的实现异步调用，可以在逻辑复杂的代码逻辑中以比较轻易的方式实现异步调用。随着逻辑的复杂，需求的更改，代码可依然能保持极强的阅读性.二,添加依赖 io.reactivex.rxjava2:rxj…
Android Rxjava架构原理与使用的详解解答
简单介绍
Rxjava这个名字，其中java代表java语言，而Rx是什么意思呢？Rx是Reactive Extensions的简写，翻译过来就是，响应式拓展。所以Rxjava的名字的含义就是，对java语言的拓展，让其可以实现对数据…
android——rxjava的使用
提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档 文章目录 前言一、rxjava是什么？二、使用步骤 1.引入库2.读入数据总结 前言 本文介绍项目开发中使用到rxjava的情形，以及详细的代码。 一、rxjava是什…
构建第一个ArkTS应用（Stage模型）
创建ArkTS工程
若首次打开DevEco Studio，请点击Create Project创建工程。如果已经打开了一个工程，请在菜单栏选择File > New > Create Project来创建一个新工程。选择Application应用开发（本文以应用开发为例，Atomic Servi…
RxJava 复刻简版之三，map 多次中转数据
案例代码：https://gitee.com/bobidali/lite-rx-java/commit/292e9227a5491f7ec6a07f395292ef8e6ff69290
RxJava 的调用第一步是封装了观察者接受了数据的处理，进一步就是使用 map 将数据操作传递给上下游
1、类似Observer.create 创建一个简单的观察者…
Kotlin手写RxJava变换符
Kotlin手写RxJava变换符
本文链接，点击这里进入
1、核心点：中转站存储之前的数据 2、三行代码实现RxJava
使用create、map、observer
fun main() {// create构造出RxJavaCore存放，lambda执行完的结果create{"WCH"}.map{ // 扩展…
RxJava/RxAndroid的操作符使用(二)
文章目录 一、创建操作1、基本创建2、快速创建2.1 empty2.2 never2.3 error2.4 from2.5 just 3、定时与延时创建操作3.1 defer3.2 timer3.3 interval3.4 intervalRange3.5 range3.6 repeat 二、过滤操作1、skip/skipLast2、debounce3、distinct——去重4、elementAt——获取指定…
Android中多线程实现
Android中多线程主要有三种实现方式：通过Thread类、AsyncTask或者RxJava。 1. 通过Thread类 我们使用Thread类时，可以创建Thread的子类并重写其run方法， 或者自定义一个实现Runable协议的类，然后将其与Thread进行绑定。将线程间数…
Android 高仿今日头条新闻客户端,可作为毕业设计
源码下载地址：https://download.csdn.net/download/yujun2023/87897511
背景
一直都想尝试开发自己还没接触过的某类APP，以前刚入门的时候，就有一个梦想：开发社交类、地图类、新闻类、支付、电商类、直播类、游戏类这些APP。社交…
Observable设计模式简介
Observable设计模式存在于许多Java API和响应式编程中。下面介绍Java中永恒的Observable模式。
Observable设计模式用于许多重要的Java API。一个众所周知的示例是使用ActionListenerAPI执行操作的JButton。在这个例子中，我们ActionListener在按钮上进行了监听或…
RxJava 操作符
build.gradle //rxjava rxandroidimplementation "io.reactivex.rxjava3:rxjava:3.1.3"implementation "io.reactivex.rxjava3:rxandroid:3.0.0"
一、概述
在 RxJava 中，一个实现了 observer 接口的对象可以订阅 observable 类的实例。订阅者…
RxJava学习资源汇总
目录 来自扔物线大神的
介绍RxJava 1.x 和 2.x 的区别 ：
介绍RxJava 2.x 中常用操作符的：
介绍使用场景的：
Rxjava源码分析：
解决Rxjava 内存泄漏的：
介绍Rxjava在空间维度和时间维度上进行“事件驱动型”编程…
手把手教你使用 RxJava 2.0（三）
本节介绍的是关于Flowabale的使用，以及RxJava 2.x中的backpressure的处理策略。这部分内容应当是RxJava 2.x中改动最大的一部分。但同时也能解决一些应用场景中的问题，使得我们的RxJava更加强大。 Flowable的产生
在RxJava中会经常遇到一种情况就是被观…
RxLifecycle详细解析
一、介绍
RxLifecycle目的：解决RxJava使用中的内存泄漏问题。
例如，当使用RxJava订阅并执行耗时任务后，当Activity被finish时，如果耗时任务还未完成，没有及时取消订阅，就会导致Activity无法被回收&#x…
手把手教你使用 RxJava 2.0（一）
网上有很多关于RxJava的技术文章，大多数是关于1.x版本的。随着 RxJava 2.0 的推出，有些文章也介绍了2.x版本新增的内容以及与1.x版本的对比。有些同学如果刚刚接触RxJava，仅仅看RxJava 1.x 的一些技术文章，有时候会有些出入。因此…
分别使用Observable、LiveData、RxJava监听List＜T＞的内容变化
在Java中，如果要监听List的内容变化，可以使用Java自带的观察者模式Observable或者第三方库(LiveData \RxJava)实现，下面分别介绍：
三者的区别优劣势、使用场景分析
下面是 Observable、LiveData、RxJava 监听 bean 对象的区别整…
RxJava/RxAndroid的基本使用方法（一）
文章目录 一、什么是RxJava二、使用前的准备1、导入相关依赖2、字段含意3、Upstream/Downstream——上/下游4、BackPressure5、BackPressure策略6、“热” and “冷” Observables7、 基类8、事件调度器9、操作符是什么？ 三、RxJava的简单用法1、Observable——Obse…
你可以不用RxJava，但必须得领悟它的思想！
作者：cofbro 前言
Rx 是一种响应式编程的思想，如今有很多语言都支持这种思想：RxJava，RxJs，RxSwift...。它是基于特殊的观察者模式来实现的，能够轻松的实现异步事件响应流，避免回调地狱的产生。…
【webFlux】嵌套的Switch语句使用响应式语法进行替代
在WebFlux中，嵌套的Switch语句可以使用响应式语法进行替代。 下面是一个示例代码，其中使用了flatMap操作符来模拟Switch语句：
Mono.just("A").flatMap(input -> {if (input.equals("A")) {return Mono.just("B&…
Android入门第65天-mvvm模式下的retrofit2+okhttp3+rxjava
开篇一个APP，它所涉及到的内容不只是APP表面这些界面、元素的beautiful和开发。APP之所以为APP它不同于VUE JS、微信小程序，一个APP它内部也分成多个层次，有纯前端、有Adapter、有模型层、有API层、有底层、有缓存、有内嵌存储。一个APP其实是…
探索低代码开发：编程新时代的开启
低代码开发是一种基于图形化界面和可视化编程的新型软件开发方法，旨在降低软件开发的技术门槛，提高开发效率和灵活性。本文将介绍低代码开发的定义、特点、优势以及示例代码，帮助读者了解低代码开发的概念及其在实际应用中的意义。
1. 什么是…
Rxjava+Retrofit实现多图片上传
1、前言
项目需求：要求实现多张图片上传，并携带其他属性值。 项目使用框架：RxjavaRetrofitOkhttp。 先附上大神写的关于Retrofit的详细用法，本文所写以此文为基础：Retrofit详解。
2、后台接口 分析后台接口&#x…
RxJava 2.0 全体系梳理(持续更新ing)
事件流 数据流
如何组合和变换流
如何订阅任何可观察的数据流
目录
一.源码解析
二.基本使用
步骤
一、创建Observable
二、创建Observer
三、使用subscribe进行订阅
四、取消订阅 Disposable
五种Observable(被观察者)
Observable 和 Observer
Cold Observable
…
Android Jetpack 从使用到源码深耕【数据库注解Room 从实践到原理 】（三）
前面两篇文章，我们一起学习了，Room引入的背景、Room的使用方式、Room的实现原理猜想验证、Room的源码原理探索总结。 本文，我们将其中牵扯到的课外知识点 or 过程中没有说到的知识点，进行一下单独的总结。
题外话：扩展知识点总结
1. 抽象工厂的设计模式应用
在源码探索…
Android RxJava框架源码解析（四）
目录一、观察者Observer创建过程二、被观察者Observable创建过程三、subscribe订阅过程四、map操作符五、线程切换原理简单示例1：
private Disposable mDisposable;
Observable.create(new ObservableOnSubscribe<String>() {Overridepublic void subscribe(…
RxJava1.x学习
前言:作为一个小菜鸟，以前都没有用过RxJava，但这都丝毫不影响我在这里BB。以前写个异步就是new Thread()new Handler()；或者是使用new AsyncTask()；来实现一个异步操作。大清早起来,就准备研究这个RxJava，想看看这个是…
Rxjava实现定时器
使用Rxjava 实现定时任务很简单，活不多说，直接上代码：
另外如果大家之前使用handler 或者 timerTask 来实现定时任务的，建议用RxTimer来替换
以下代码两个方法
a.timer() 延时指定时间后执行
b.interval() 延时指定时间后&…
Rxjava retryWhen and repeatWhen
retry
当Observable发生错误时接收到onError事件，重新发射数据。可以拦截Throwable 和 Exception。
重载方法如下： // 一直错误，一直重试
public final Observable<T> retry() {return retry(Long.MAX_VALUE, Functions.alwaysTrue()…
【Java万花筒】Java函数式编程库全面解析：Stream API、Functional Java、Vavr、Guava、RxJava
函数式编程之光：Java库的精髓剖析与实际应用
前言
Java在近年来的发展中引入了丰富的函数式编程库，为开发者提供了更灵活、简洁的工具来处理数据和异步操作。本文将深入探讨Java 8的Stream API，以及几个主要的函数式编程库：Func…
FyListen 在 MVP 架构中的内存优化表现
FyListen 在 MVP 中的内存优化表现
本文只是分享个人开源框架的内存优化测试，你可以直接跳到最后，参考内存泄漏的分析过程！
项目地址： https://github.com/StudyNoteOfTu/fylisten2-alpha1
由于使用到 AOP，所以直接…
RxJava2 事件分发消费绑定逻辑 简析
前言
重温RxJava2源码，做个简单的记录，本文仅分析事件的发射与消费简单逻辑，从源码角度分析被观察者（上游事件）是如何与观察者（下游事件）进行关联的。
事件发射
Observable.just(1,2,3).subs…
Android Retrofit2+Rxjava2 的demo
https://download.csdn.net/download/hknishi_zs/11085087
推荐框：
https://github.com/Kaopiz/KProgressHUD
【Rxjava详解】(四)线程切换
lift()变换原理
这些变换虽然功能各有不同，但实质上都是针对事件序列的处理和再发送。而在RxJava的内部，它们是基于同一个基础的变换方法：lift()。
首先看一下lift() 的内部实现（仅显示了部分主要逻辑代码):
public <R> …
Android--WebSocket
WebSocket 是一种双向通信协议，在建立连接后，WebSocket服务器和 Browser/Client Agent 都能主动的向对方发送或接收数据，就像 Socket一样。它类似TCP长连接，但是WebSocket使用的是ws和wss两种通信协议，所以这是完全不同…
动态代理View 实现无感化的用户状态检测框架
user-state-check
基于AOP实现用户状态检测的框架
github地址: user-state-check
功能
通过dexmaker 实现动态代理，通过设置ViewFactory2，动态生成view的子类。配合xml中定义属性。可以无感的拦截任意view的点击事件通过dexMaker 实现AOP，…
手把手教你使用 RxJava 2.0（二）
本篇文章主要介绍线程调度器，通过对线程调度器的了解，方便我们更好的处理异步操作，在合适的场景选择合适的线程。同时，结合上篇文章，我们就初步掌握了 RxJava 2.x的基本操作并可以应用在我们的项目中。在本篇文章的后半…
知识点补充_RxJava
知识点补充_RxJava
推荐网址 http://gank.io/post/560e15be2dca930e00da1083
http://blog.csdn.net/qq_35064774/article/details/53057332
https://juejin.im/post/5848d96761ff4b0058c9d3dc
RxJava 到底是什么
响应式编程（Reactive programming）…