极客教程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...