提供了编程的基础技术教程

zl程序教程

rxjava之操作符

  • RxJava 操作符flatmap

    RxJava 操作符flatmap

    大家好，又见面了，我是你们的朋友全栈君。 有如下场景： 在前段调用后端的API时，经常会出现回调嵌套的情况。假设我们有两个API，queryA 和 queryB. 并且queryB的运行依赖于queryA的结果。那么我们的程序在一般的情况下可能是这个样子。 想象有如下的代码: 是不是感觉非常不舒服？假如嵌套的API再多几层，那么这将是个灾难。一个人开发的时候可能不觉得有什么问题，但是可以

    日期 2023-06-12 10:48:40     
  • RxJava（三） flatMap 操作符用法详解

    RxJava（三） flatMap 操作符用法详解

    大家好，又见面了，我是你们的朋友全栈君。 RxJava 系列文章目录导读： 一、RxJava create 操作符的用法和源码分析 二、RxJava map 操作符用法详解 三、RxJava flatMap 操作符用法详解 四、RxJava concatMap 操作符用法详解 五、RxJava onErrorResumeNext 操作符实现 app 与服务器间 token 机制 六、

    日期 2023-06-12 10:48:40     
  • RxJava（七） 使用 debounce 操作符优化 App 搜索功能[通俗易懂]

    RxJava（七） 使用 debounce 操作符优化 App 搜索功能[通俗易懂]

    大家好，又见面了，我是你们的朋友全栈君。 RxJava 系列文章目录导读： 一、RxJava create 操作符的用法和源码分析 二、RxJava map 操作符用法详解 三、RxJava flatMap 操作符用法详解 四、RxJava concatMap 操作符用法详解 五、RxJava onErrorResumeNext 操作符实现 app 与服务器间 token 机制 六、

    日期 2023-06-12 10:48:40     
  • java实现debounce_Rxjava debounce 操作符

    java实现debounce_Rxjava debounce 操作符

    大家好，又见面了，我是你们的朋友全栈君。Debounce1.官方定义only emit an item from an Observable if a particular timespan has passed without it emitting another itemThe Debounce operator filters out items emitted by the source

    日期 2023-06-12 10:48:40     
  • SpringCloudRPC核心原理：RxJava响应式编程框架，创建型操作符

    SpringCloudRPC核心原理：RxJava响应式编程框架，创建型操作符

    创建型操作符创建型操作符用于创建一个可观察对象Observable主题对象并弹出数据。RxJava的创建型操作符比较多，大致如下：（1）create（）：使用函数从头创建一个Observable主题对象。（2）defer（）：只有当订阅者订阅才创建Observable主题对象，为每个订阅创建一个新的Observable主题对象。（3）range（）：创建一个弹射指定范围的整数序列的Observab

    日期 2023-06-12 10:48:40     
  • SpringCloudRPC调用核心原理：RxJava响应式编程框架，聚合操作符

    SpringCloudRPC调用核心原理：RxJava响应式编程框架，聚合操作符

    聚合操作符本节介绍RxJava的两个聚合型操作符：count操作符和reduce操作符。count操作符count操作符用来对源Observable流的数据项进行计数，最后将总数弹射出来；如果源流弹射错误，就会将错误直接报出来；在源Observable流没有终止前，count操作符是不会弹射统计数据的。使用count操作符对数据流序列进行计数，具体的执行流程如图4-9所示。图4-9 使用count

    日期 2023-06-12 10:48:40     
  • RxJava 之 create操作符 源码解析

    RxJava 之 create操作符 源码解析

    转载请以链接形式标明出处： 本文出自:103style的博客 本文基于 RxJava 2.x 版本create操作符例子：Observable .create(new ObservableOnSubscribe<Object>() { @Override public void subscribe(Observabl

    日期 2023-06-12 10:48:40     
  • Rxjava之from系列操作符源码解析

    Rxjava之from系列操作符源码解析

    转载请以链接形式标明出处： 本文出自:103style的博客 from 系列操作符包括以下操作符：fromArray(T... items) : 参数 数组长度 为 0 是执行 empty操作符，长度为 1 时，是执行 just操作符。public static <T> Observable<T> fromArray(T... items) { if (ite

    日期 2023-06-12 10:48:40     
  • RxJava之创建操作符源码介绍

    RxJava之创建操作符源码介绍

    转载请以链接形式标明出处： 本文出自:103style的博客 前言前置阅读：RxJava之create操作符源码解析Rxjava 之 创建操作符 官方介绍 ：Creating-Observables创建相关的操作符 以及 官方介绍createdeferemptyerrorfromgenerateintervaljustneverrangetimer前置阅读：Rxjava之create操作符源

    日期 2023-06-12 10:48:40     
  • RxJava之timer和interval操作符源码解析

    RxJava之timer和interval操作符源码解析

    转载请以链接形式标明出处： 本文出自:103style的博客 timer 操作符timer 操作符实际上返回的是一个 ObservableTimer对象。两个参数的方法默认在 Schedulers.computation()中工作。 public static Observable<Long> timer(long delay, TimeUnit unit) { ret

    日期 2023-06-12 10:48:40     
  • RxJava之转换操作符源码介绍

    RxJava之转换操作符源码介绍

    转载请以链接形式标明出处： 本文出自:103style的博客 转换相关的操作符 以及 官方介绍RxJava 之 转换操作符 官方介绍 ：Transforming ObservablesbuffercastconcatMapconcatMapXXXflatMapflatMapXXXflattenAsFlowableflattenAsObservablegroupBymapscanswitchM

    日期 2023-06-12 10:48:40     
  • RxJava之concatMap系列转换操作符源码介绍

    RxJava之concatMap系列转换操作符源码介绍

    转载请以链接形式标明出处： 本文出自:103style的博客 转换相关的操作符 以及 官方介绍RxJava 之 concatMap 系列 转换操作符 官方介绍 ：Transforming ObservablesconcatMapconcatMapCompletableconcatMapCompletableDelayErrorconcatMapDelayErrorconcatMapEager

    日期 2023-06-12 10:48:40     
  • RxJava之flatMap系列转换操作符

    RxJava之flatMap系列转换操作符

    转载请以链接形式标明出处： 本文出自:103style的博客 转换相关的操作符 以及 官方介绍RxJava 之 flatMap 系列 转换操作符 官方介绍 ：Transforming ObservablesflatMapflatMapCompletableflatMapIterableflatMapMaybeflatMapObservableflatMapPublisherflatMapSi

    日期 2023-06-12 10:48:40     
  • RxJava之过滤操作符介绍

    RxJava之过滤操作符介绍

    转载请以链接形式标明出处： 本文出自:103style的博客 过滤相关的操作符 以及 官方介绍RxJava 之 过滤操作符 官方介绍 ：Filtering ObservablesdebouncedistinctdistinctUntilChangedelementAtelementAtOrErrorfilterfirstfirstElementfirstOrErrorignoreElemen

    日期 2023-06-12 10:48:40     
  • RxJava之组合操作符介绍

    RxJava之组合操作符介绍

    转载请以链接形式标明出处： 本文出自:103style的博客 组合相关的操作符 以及 官方介绍RxJava 之 组合操作符 官方介绍 ：Combining ObservablescombineLatestjoin and groupJoinmergemergeDelayErrorrxjava-joins–and、then、whenstartWithswitchOnNextzipcombine

    日期 2023-06-12 10:48:40     
  • RxJava之异常捕获操作符介绍

    RxJava之异常捕获操作符介绍

    转载请以链接形式标明出处： 本文出自:103style的博客 异常捕获相关的操作符 以及 官方介绍RxJava 之 异常捕获操作符 官方介绍 ：Error Handling OperatorsdoOnErroronErrorCompleteonErrorResumeNextonErrorReturnonErrorReturnItemonExceptionResumeNextretryretr

    日期 2023-06-12 10:48:40     
  • RxJava之连接操作符介绍

    RxJava之连接操作符介绍

    转载请以链接形式标明出处： 本文出自:103style的博客 连接相关的操作符 以及 官方介绍RxJava 之 连接操作符 官方介绍 ：Connectable Observable Operators ConnectableObservable.connect( ) instructs a Connectable Observable to begin emitting items 指

    日期 2023-06-12 10:48:40     
  • rxjava之操作符

    rxjava之操作符

    1.1.转换类操作符(map  flatMap  concatMap  flatMapIterable   switchMap   scan   groupBy...)； 1.2过滤类操作符(fileter take takeLast takeUntil distinct distinctUntilChan

    日期 2023-06-12 10:48:40     
  • RxJava【创建】操作符 create just from defer timer interval MD

    RxJava【创建】操作符 create just from defer timer interval MD

    Markdown版本笔记 我的GitHub首页 我的博客 我的微信 我的邮箱 MyAndroidBlogs baiqiantao baiqiantao bqt20094 baiqiantao@sina.com RxJava【创建】操作符 create just from defer timer interval MD demo地址

    日期 2023-06-12 10:48:40     
  • RxJava【过滤】操作符 filter distinct throttle take skip first MD

    RxJava【过滤】操作符 filter distinct throttle take skip first MD

    Markdown版本笔记 我的GitHub首页 我的博客 我的微信 我的邮箱 MyAndroidBlogs baiqiantao baiqiantao bqt20094 baiqiantao@sina.com RxJava【过滤】操作符 filter distinct throttle take skip first MD demo地

    日期 2023-06-12 10:48:40     
  • RxJava【变换】操作符 map flatMap concatMap buffer MD

    RxJava【变换】操作符 map flatMap concatMap buffer MD

    Markdown版本笔记 我的GitHub首页 我的博客 我的微信 我的邮箱 MyAndroidBlogs baiqiantao baiqiantao bqt20094 baiqiantao@sina.com RxJava【变换】操作符 map flatMap concatMap buffer MD demo地址 参考

    日期 2023-06-12 10:48:40     
  • RxJava 操作符 on和doOn 线程切换 调度 Schedulers 线程池 MD

    RxJava 操作符 on和doOn 线程切换 调度 Schedulers 线程池 MD

    Markdown版本笔记 我的GitHub首页 我的博客 我的微信 我的邮箱 MyAndroidBlogs baiqiantao baiqiantao bqt20094 baiqiantao@sina.com RxJava 操作符 on和doOn 线程切换 调度 Schedulers 线程池 MD 目录 目录RxJava 线程池

    日期 2023-06-12 10:48:40     
  • Android RxJava使用介绍（三） RxJava的操作符

    Android RxJava使用介绍（三） RxJava的操作符

    上一篇文章已经具体解说了RxJava的创建型操作符。本片文章将继续解说RxJava操作符。包括： Transforming Observables(Observable的转换操作符) Filtering Observables(Observable的过滤操作符) Transforming Observables(Observable的转换操作符) buffer操作

    日期 2023-06-12 10:48:40     
  • RxJava操作符总结之过滤

    RxJava操作符总结之过滤

    RxJava操作符总结之过滤 jsut() just(T t1, T t2, T t3 ....) ，just能够传入多个同样类型的參数，并将当前參数一个接着一个的发送。 Observable.just("1","2","3") .subscribe(new Action1<String>() {

    日期 2023-06-12 10:48:40     
  • RxJava 和 RxAndroid 二（操作符的使用）

    RxJava 和 RxAndroid 二（操作符的使用）

    前言：对Rx不了解的朋友可以先看我的第一篇博文 RxJava 和 RxAndroid 一 (基础)，是对Rxjava的基本介绍   1、merge操作符，合并观察对象 19 List<String> list1 = new ArrayList<>() ; 20 List<String> list2 = n

    日期 2023-06-12 10:48:40     
  • Rxjava学习(二操作符)

    Rxjava学习(二操作符)

    操作符是为了解决对Observable对象的变换的问题，操作符用于在Observable和最终的Subscriber之间修改Observable发出的事件 1.filter   filter()操作符是可以对Observable流程的数据进行一层过滤处理,返回一个新的Observable,filter()返回为false的值将不会发出到Subscriber,我们来看下具体的代

    日期 2023-06-12 10:48:40     
  • Android RxJava使用介绍（四） RxJava的操作符

    Android RxJava使用介绍（四） RxJava的操作符

    本篇文章继续介绍下面类型的操作符 Combining Observables(Observable的组合操作符) Error Handling Operators(Observable的错误处理操作符) Combining Observables(Observable的组合操作符) combineLatest操作符 combineLatest操作符把两个Obse

    日期 2023-06-12 10:48:40     
  • RxJava系列之二 变换类操作符具体解释1

    RxJava系列之二 变换类操作符具体解释1

    1.回想 上一篇文章我们主要介绍了RxJava , RxJava 的Observables和 RxJava的just操作符。以及RxJava一些经常使用的操作。 没看过的抓紧点我去看吧。 事实上RxJava有非常多的操作符， 而我们学过的just仅仅是创建类操作符的当中一种。以后我会陆续介绍其它的创建类操作符。 文章代码地址：https://github.com

    日期 2023-06-12 10:48:40