rx专题

深入理解RxJava:响应式编程的现代方式

在当今的软件开发世界中,异步编程和事件驱动的架构变得越来越重要。RxJava,作为响应式编程(Reactive Programming)的一个流行库,为Java和Android开发者提供了一种强大的方式来处理异步任务和事件流。本文将深入探讨RxJava的核心概念、优势以及如何在实际项目中应用它。 文章目录 💯 什么是RxJava?💯 响应式编程的优势💯 RxJava的核心概念

RxJava zip 使用

间隔发送: String[] codes = irCodeStr.split("\\|");Observable<String> codesDate = Observable.fromArray(codes);Observable<Long> intervalDate = Observable.interval(interval, TimeUnit.MILLISE

在Java中异步编程,同事非要用rxJava,被我一顿吐槽!

点击上方“朱小厮的博客”,选择“设为星标” 后台回复"书",获取 在Java中异步编程,不一定非要使用rxJava, Java本身的库中的CompletableFuture可以很好的应对大部分的场景。 这篇文章介绍 Java 8 的 CompletionStage API和它的标准库的实现 CompletableFuture。API通过例子的方式演示了它的行为,每个例子演示一到两个行为。

与RxJava的第一次接触

转载请注明出处 作者:AboutJoke ( http://blog.csdn.net/u013200308 ) 原文链接:http://blog.csdn.net/u013200308/article/details/53559707 初识 RxJava出来有一年多了吧,但貌似理解和使用的人不是很多的样子,我也是由于使用Retrofit才接触到。那么RxJava是什么呢?GitHub

Cannot resolve method compose(rx.observable.transformer)

ApiService 中Observable的包倒错了,应该是import io.reactivex.Observable; 不是这个 import android.database.Observable;

Android Rxjava操作符使用详情(一)

一、简单介绍: 函数响应式编程可以极大简化项目,特别是处理嵌套回调、复杂的列表过滤和变换或者时间相关问题。Rxjava就是在android开发中使用函数响应式编程的框架。 二、Rxjava原理: 创建一个Observable对象来干活,然后使用各种操作符建立起来的链式操作,就如同流水线一样,把你想要处理的数据一步一步地加工成你想要的成品,然后发射给Subscriber处理。 三、Rxjav

常用rxjava操作符

RxJava 操作符 阅读本文前请先了解 RxJava 的基本使用。转自 http://blog.csdn.net/u014165119/article/details/52582782 参考文档: RxJava JavaDocReactiveX文档中文翻译 1 Observable 的创建 1.1 from( ) 转换集合为一个每次发射集合中一个元素的 Observable 对象。

Rxjava2的介绍与使用(一:详解)

一、介绍 RXJava2是基于观察者模式和链式编程思想的异步编程库,它可以用来优雅地处理异步操作,比如网络请求、数据库查询、文件I/O等操作,减少了回调嵌套,提高了代码的可读性和可维护性。 二、特点 异步处理:RXJava2的异步处理可以避免主线程被阻塞,提高应用的响应速度。链式编程:RXJava2使用链式编程的方式,使得代码更加简洁、易读、易维护。统一处理异步任务:RXJava2提供了统一

rxjava调研

rxjava适合异步的场景,可以很方便的处理数据流。不过在后端,大多数都是同步的代码,如果有异步的可以尝试使用rxJava来解决问题。

Retrifit2+RxJava2 实现MVP

第1步 在build.gradle中引入    // Retrofit库implementation 'com.squareup.retrofit2:retrofit:2.3.0'implementation 'com.squareup.retrofit2:converter-gson:2.3.0'implementation 'com.squareup.retrofit2:adapter-rx

Rxjava2集锦

Rxjava2 基本使用: //1、创建被观察者ObservableObservable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {@Overridepublic void subscribe(ObservableEmitter<String> e) throws Excepti

RxJava常用操作符 Observable.fromIterable

import io.reactivex.Observable val bannerItemData: ArrayList<HomeBean.Issue.Item> = mData.take(bannerItemSize).toCollection(ArrayList())val bannerFeedList = ArrayList<String>()val bannerTitleList =

Rxjava2最全面的解析

说到区别,可能有的小伙伴会问,我没看过rxjava1。可以直接看rxjava2么。个人觉得不必要,因为 rxjava2.x 是按照 Reactive-Streams specification 规范完全的重写的,完全独立于 rxjava1.x 而存在,它改变了以往 rxjava1的用法。换句话说,我学java需不需要先学C语言一样。 那么两者的区别体现在哪呢?主要是如下几个方面: 空指针问题

Android 开源项目Kotlin+MVP+Retofit2+RxJava2架构开发一款短视频App

KotlinMvp GitHub地址:https://github.com/git-xuhao/KotlinMvp (开源不易,喜欢的话希望给个 Star 或者 Fork,谢谢!) 《KotlinMvp》 是仿着“开眼Eyepetizer”之前版本并加上自己的想法,开发的一款的短视频小应用,每日为你推荐精选视频,让你大开眼界。本项目采用 Kotlin 语言编写,结合 MVP+RxJava2+

收包软中断和netif_rx (linux网络子系统学习 第四节 )

初始化报文接收软中断 static int __init net_dev_init(void){......open_softirq(NET_RX_SOFTIRQ, net_rx_action);......} 报文接收软中断的处理函数net_rx_action详解: static void net_rx_action(struct softirq_action *h){/*取得本地

【INTEL(ALTERA)】为什么 F-Tile DisplayPort FPGA IP 设计示例无法通过高比特率 3 (HBR3) 的 RX 链路调训?

目录 说明 解决方法 说明 由于 Quartus® Prime Pro Edition 软件版本 v23.3 和 v23.4 生成的 F-Tile DisplayPort FPGA IP 设计示例中存在问题,您可能会在 HBR3 上观察到 RX 链路训练失败。 解决方法 要在这些软件版本中变通解决此问题,请使用以下 RxEQ 参数编辑项目 Quartus 设置文件 (.qsf)

Kotlin 实现的基于 RxJava 2.× 的 RxBus

实现 既然你主动打开了这篇文章,那你肯定了解 RxBus 是什么,以及 RxBus 是干什么用的。所以我就偷个懒不陪你复习基础知识了 #滑稽,下面直接贴代码。 Kotlin 实现的基于 RxJava 2.× 的 RxBus 单例: object RxBus {// 支持背压且线程安全的,保证线程安全需要调用 toSerialized() 方法private val mBus: Flowable

Rxbus实现事件总线(RxJava2.0)

封装base的时候想到事件分发 既然用到了Rxjava 很神奇的发现了Rxbus这个东西,那就学习下~Github:https://github.com/balckban/RxbusDemo-RxJava2.0- ezgif-1-3b2413c862.gif 首先是gradle的配置 compile "io.reactivex.rxjava2:rxjava:2.1.3"comp

RxJava2_4:并行处理请求和数据缓存池

RxJava2_4:并行处理请求和数据缓存池 参考: http://www.jianshu.com/p/1f4867ce3c01 https://juejin.im/user/573dba2171cfe448aa97b7b0   并行处理: 为了解决并行的请求和数据处理,我们可以采用zip来进行。 通过zip我们可以将管道流A和管道流B请求的数据进行1+1对应的

RXjava2_3:数据的转换和回调嵌套的解决

RXjava2_3:数据的转换和回调嵌套的解决 参考: http://blog.csdn.net/jdsjlzx/article/details/51493552 https://juejin.im/post/5848dd3eac502e00691385c5   数据的转换 map方法数据转换:     Flatmap方法的转换:   map”v

RxJava2_2:流程及关键对象的理解

RxJava2:流程及关键对象的理解 参考: http://blog.csdn.net/column/details/rxjava.html?&page=2     (这个是rxjava1的) https://juejin.im/post/5848d96761ff4b0058c9d3dc http://www.jianshu.com/p/404a4d9b415a   流程: r

RxJava和Retrofit的介绍

一、ReactiveX简单介绍 Rx是一个使用可观察数据流进行异步编程的编程接口,ReactiveX结合了观察者模式、迭代器模式和函数式编程的精华。Rx提供了一系列的操作符,你可以使用它们来过滤(filter)、选择(select)、变换(transform)、结合(combine)和组合(compose)多个Observable,这些操作符让执行和复合变得非常高效。 在Reactive

Retrofit使用教程(三):Retrofit与RxJava初相逢(个人感觉好理解一些)

时间 2016-03-25 00:17:13 DevWiki's Blog 原文  http://www.devwiki.net/2016/03/25/Retrofit-Use-Course-3/ 主题 RxJava Retrofit 上一篇文章讲述了Retrofit的基本使用,包括GET,POST等请求.今天的文章中Retrofit要与RxJava配合使用. 了解R

分享 Retrofit+RxJava+MPAndroidChart 未来一周天气气温预测案例

作者: panyz , 原文链接: http://www.jianshu.com/p/696ca77c2697 用 Retrofit+RxJava+MPAndroidChart 开发未来一周天气气温预测小案例 —— 由 panyz 分享 前言 上周我写了一篇MPAndroidChart的使用技巧 ,得到了不少人的响应。至少自己写的文章还是有人去看,很是激励。毕竟我在学习Andr

带你入门学习Rxjava--上手教程

相信各位看官对RxJava早有耳闻,那么关于什么是RxJava我就不再赘述了,不知道的可自行百度。网上的RxJava的入门门槛稍高,但入门不难,可以跟本文一起来学习 注: 本文针对rxjava 1.x.x ,用例为下,建议初学先从1.x看起     compile 'io.reactivex:rxjava:1.1.6'     compile 'io.reactivex:rxandroid:

用RxJava实现Rxbus替换EventBus事件总线

首先,Rxjava不必多说,可以说和Retrofit是年度最火框架,在GitHub上都已经超过两万star,Eventbus也不必多说,目前大多数开发者大多数项目一定会用到EventBus或者Otto作为事件总线通信库,对于RxJava使用者来说,RxJava也可以轻松实现事件总线,因为它们都依据于观察者模式。本文介绍Rxbus如何完美替换Eventbus,减少APP体积.