极客教程RxJava 窗口操作符
RxJava 窗口操作符 窗口操作符与缓冲操作符类似，但它允许将由Observable发射的项目收集到另一个Observable中，而不是集合，并发射这些Observables而不是集合。在下面的示例中，我们创建了一个Observable来...
RxJava
RxJava 缓冲
RxJava 缓冲 缓冲操作符允许收集Observable发出的项目到一个列表或包裹中，并发出这些包裹而不是项目。在下面的示例中，我们创建了一个Observable用于发出9个项目，并使用缓冲操作符，每次发出3个项目。 缓冲示例 使用任何编...
RxJava from调度器
RxJava from调度器 Schedulers.from(Executor) 方法将一个 Executor 转换为一个新的 Scheduler 实例。 Schedulers.from(Executor) 示例 使用您选择的任何编辑器，在...
RxJava IO Scheduler
RxJava IO Scheduler Schedulers.io()方法创建并返回一个适用于IO密集型工作的调度器。线程池可根据需要进行扩展。最适用于I/O密集型操作。 Schedulers.io()示例 使用你喜欢的任何编辑器在C:&#...
RxJava 计算调度器
RxJava 计算调度器 Schedulers.computation()方法创建并返回一个用于计算工作的调度器。要调度的线程数取决于系统中的CPU数量。每个CPU允许一个线程。最适合事件循环或回调操作。 Schedulers.comput...
RxJava NewThread调度器
RxJava NewThread调度器 Schedulers.newThread()方法创建并返回一个调度器，该调度器为每个工作单元创建一个新的线程。 Schedulers.newThread()示例 使用您选择的任何编辑器，在C:>...
RxJava Trampoline Scheduler
RxJava Trampoline Scheduler Schedulers.trampoline()方法创建并返回一个调度器，该调度器将工作排队到当前线程在当前工作完成后执行。 Schedulers.trampoline()示例 使用您选...
RxJava 调度程序
RxJava 调度程序 调度程序用于在多线程环境中与Observable操作符一起工作。 根据Reactive的定义，调度程序用于安排操作符链在不同线程上的应用方式。 默认情况下，Observable及其应用的操作符链将在调用其Subscr...
RxJava AsyncSubject
RxJava AsyncSubject AsyncSubject在发送完最后一个值后，会发送一个完成事件或接收到的错误给订阅者。 类声明 以下是io.reactivex.subjects.AsyncSubject类的声明： public f...
RxJava ReplaySubject
RxJava ReplaySubject ReplaySubject将事件/项回放给当前和晚到的观察者。 类声明 以下是 io.reactivex.subjects.ReplaySubject 类的声明。 public final clas...
RxJava BehaviorSubject
RxJava BehaviorSubject BehaviorSubject会将观察到的最新项以及所有后续观察到的项发送给每个订阅的观察者。 类声明 以下是 **io.reactivex.subjects.BehaviorSubject *...
RxJava PublishSubject
RxJava PublishSubject PublishSubject将项目发送给当前订阅的观察者，并将最终事件发送给当前或延迟的观察者。 类声明 以下为 io.reactivex.subjects.PublishSubject 类的声明...
RxJava Subjects
RxJava Subjects 根据 Reactive ，Subject既可以充当Observable，又可以充当Observer。 Subject是ReactiveX的一种实现中可用的一种桥梁或代理，它既充当观察者又充当Observabl...
RxJava 连接操作符
RxJava 连接操作符 以下是具有更精确订阅控制的操作符。 序号 运算符与描述 1 Connect 通知可连接的Observable向其订阅者发送项。 2 Publish 将一个Observable转换为可连接的Observable。 3...
RxJava 数学运算符
RxJava 数学运算符 以下是对由Observable发出的所有项进行操作的运算符。 序号 运算符和描述 1 Average 计算所有项的平均值并输出。 2 Concat 在不交替的情况下输出多个可观察对象的所有项。 3 Count 计算...
RxJava 条件操作符
RxJava 条件操作符 以下是一个或多个被发射的Observable或项目的评估操作符。 Sr.No. 操作 & 描述 1 All 评估所有发出的项目以满足给定的条件。 2 Amb 仅在多个Observables给出的情况下从第一...
RxJava 实用操作符
RxJava 实用操作符 以下是在 Observables 中经常使用的操作符。 序号 操作符和说明 1 Delay 注册一个操作以处理Observable的生命周期事件。 2 Materialize/Dematerialize 表示发出的...
RxJava 合并操作符
RxJava 合并操作符 以下是用于从多个 Observables 创建单个 Observable 的操作符。 序号 运算符及描述 1 And/Then/When 使用Pattern和Plan中介程序组合项目集。 2 CombineLate...
RxJava 过滤操作符
RxJava 过滤操作符 以下是用于从Observable有选择地发出项目的操作符。 序号 运算符与描述 1 Debounce 仅在超时后未发射另一个项时发射项。 2 Distinct 仅发射唯一项。 3 ElementAt 仅发射由 Ob...
RxJava 转换操作符
RxJava 转换操作符 以下是用于转换由Observable发出的项目的操作符。 序号 运算符和说明 1 Buffer 定期将Observable中的项目收集到捆绑中，然后发射捆绑而不是项目。 2 FlatMap 在嵌套的Observab...
RxJava 创建操作符
RxJava 创建操作符 下面是用于创建Observable的操作符。 序号 操作符和描述 1 Create 从头开始创建Observable，并允许观察者方法以编程的方式调用。 2 Defer 在观察者订阅之前不创建Observable。...
RxJava 使用 CompositeDisposable
RxJava 使用 CompositeDisposable CompositeDisposable 类表示一个容器，可以保存多个 disposable，并且提供了添加和删除 disposable 的 O(1) 复杂度。 类声明 以下是对 i...
RxJava Completable Observable
RxJava Completable Observable Completable类代表了延迟的响应。Completable观察者既可以表示成功完成，也可以表示错误。 类声明 以下是 io.reactivex.Completable 类的声...
RxJava MayBe Observable
RxJava MayBe Observable MayBe类表示延迟响应。MayBe可观察对象可以发射单个成功值或者没有值。 类声明 以下是 **io.reactivex.Single ** 类的声明− public abstract cl...
RxJava Single Observable
RxJava Single Observable Single类代表单个值的响应。单个可观察对象只能发出一个成功的值或一个错误。它不会发出onComplete事件。 类声明 下面是 **io.reactivex.Single ** 类的声明...
RxJava 创建 Observables
RxJava 创建 Observables 以下是创建 Observables 的基本类。 Flowable − 0..N 个流，可发出 0 或 n 个项。支持 Reactive-Streams 和背压。 Observable − 0..N...
RxJava Observable的工作原理
RxJava Observable的工作原理 Observables 代表数据的来源，而 Observers（订阅者） 监听它们。简而言之，Observable发出项目，Subscriber消耗这些项目。 Observable 当订阅者开始...
RxJava 环境搭建
RxJava 环境搭建 本地环境搭建 RxJava是一个针对Java的库，因此首要要求是在您的计算机上安装有JDK。 系统要求 JDK 1.5 or above. Memory No minimum requirement. Disk Sp...
RxJava 概述
RxJava 概述 RxJava是基于Java的ReactiveX的扩展。它提供了在Java中实现ReactiveX项目的功能。RxJava具有以下关键特性。 扩展了观察者模式。 支持数据/事件的序列。 提供操作符以声明方式将序列组合在一起...
RxJava 教程
RxJava 教程 RxJava是ReactiveX的Java扩展。ReactiveX是一个旨在向各种编程语言提供反应式编程概念的项目。反应式编程是指程序根据数据出现的时间作出反应的场景。它是一种事件驱动的编程概念，事件可以传播给注册的观察...