📅  最后修改于: 2020-11-12 05:29:55        🧑  作者: Mango

以下是对Observable发出的整个项目进行操作的运算符。Sr.No.Operator & Description1AverageEvaluates averages of all items and emit the result.2ConcatEmits all items from multiple Observable without interleaving.3CountCounts ...

📅  最后修改于: 2020-11-12 05:30:11        🧑  作者: Mango

以下是可以更精确地控制订阅的运算符。Sr.No.Operator & Description1ConnectInstruct a connectable Observable to emit items to its subscribers.2PublishConverts an Observable to connectable Observable.3RefCountConverts a co...

📅  最后修改于: 2020-11-12 05:30:25        🧑  作者: Mango

根据反应式，主体可以同时充当可观察者和观察者。主题是一种在ReactiveX的某些实现中可用的桥梁或代理，它既充当观察者又充当Observable。因为它是观察者，所以可以订阅一个或多个Observable，并且因为它是Observable，所以可以通过释放观察到的项来传递它们，也可以发出新的项。有四种类型的主题-Sr.No.Subject & Description1Publish Subjec...

📅  最后修改于: 2020-11-12 05:30:40        🧑  作者: Mango

PublishSubject向当前订阅的观察者发出项目，向当前或晚期观察者发出终端事件。类声明以下是io.reactivex.subjects.PublishSubject <T>类的声明-PublishSubject示例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。ObservableTester.java验证结果使用javac编译器编译类，如下所示：现在如下运行O...

📅  最后修改于: 2020-11-12 05:30:56        🧑  作者: Mango

BehaviorSubject发出它观察到的最新项目，然后将所有后续观察到的项目发送给每个订阅的Observer。类声明以下是io.reactivex.subjects.BehaviorSubject <T>类的声明-BehaviorSubject示例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。ObservableTester.java验证结果使用javac编译器编...

📅  最后修改于: 2020-11-12 05:31:11        🧑  作者: Mango

ReplaySubject向当前和后期的观察者重放事件/项目。类声明以下是io.reactivex.subjects.ReplaySubject <T>类的声明-ReplaySubject示例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。ObservableTester.java验证结果使用javac编译器编译类，如下所示：现在如下运行ObservableTester...

📅  最后修改于: 2020-11-12 05:31:26        🧑  作者: Mango

AsyncSubject发出唯一的最后一个值，后跟完成事件或接收到的错误给Observers。类声明以下是io.reactivex.subjects.AsyncSubject <T>类的声明-AsyncSubject示例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。ObservableTester.java验证结果使用javac编译器编译类，如下所示：现在如下运行Ob...

📅  最后修改于: 2020-11-12 05:31:41        🧑  作者: Mango

调度程序在多线程环境中用于与Observable运算符。根据Reactive，Scheduler用于计划运算符链如何应用于不同的线程。默认情况下，一个Observable及其所应用的运算符链将在调用其Subscribe方法的同一线程上完成其工作，并通知其观察者。 SubscribeOn运算符通过指定应在其上运行Observable的另一个Scheduler来更改此行为。 ObserveOn运算符指...

📅  最后修改于: 2020-11-12 05:31:57        🧑  作者: Mango

Schedulers.trampoline()方法创建并返回一个Scheduler，该Scheduler在当前工作完成后将要在当前线程上执行的工作排队。Schedulers.trampoline()示例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。ObservableTester.java验证结果使用javac编译器编译类，如下所示：现在如下运行ObservableT...

📅  最后修改于: 2020-11-12 05:32:13        🧑  作者: Mango

Schedulers.newThread()方法创建并返回一个Scheduler，该Scheduler为每个工作单元创建一个新的Thread。Schedulers.newThread()示例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。ObservableTester.java验证结果使用javac编译器编译类，如下所示：现在如下运行ObservableTester-...

📅  最后修改于: 2020-11-12 05:32:29        🧑  作者: Mango

Schedulers.computation()方法创建并返回一个用于计算工作的Scheduler。要调度的线程数取决于系统中存在的CPU。每个CPU允许一个线程。最适合事件循环或回调操作。Schedulers.computation()示例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。ObservableTester.java验证结果使用javac编译器编译类，如下...

📅  最后修改于: 2020-11-12 05:32:45        🧑  作者: Mango

Schedulers.io()方法创建并返回用于IO绑定工作的Scheduler。线程池可以根据需要扩展。最适合I / O密集型操作。Schedulers.io()示例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。ObservableTester.java验证结果使用javac编译器编译类，如下所示：现在如下运行ObservableTester-它应该产生以下输出-...

📅  最后修改于: 2020-11-12 05:33:00        🧑  作者: Mango

Schedulers.from(Executor)方法将Executor转换为新的Scheduler实例。Schedulers.from(Executor)示例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。ObservableTester.java验证结果使用javac编译器编译类，如下所示：现在如下运行ObservableTester-它应该产生以下输出-...

📅  最后修改于: 2020-11-12 05:33:16        🧑  作者: Mango

缓冲运算符允许将Observable发出的项目收集到列表或捆绑中，并发出这些捆绑而不是物品。在下面的示例中，我们创建了一个Observable来发出9个项目，并使用缓冲，将一起发出3个项目。缓冲实例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。ObservableTester.java验证结果使用javac编译器编译类，如下所示：现在如下运行ObservableTes...

📅  最后修改于: 2020-11-12 05:33:33        🧑  作者: Mango

窗口运算符的工作方式类似于缓冲区运算符，但是它允许将一个Observable发出的项目收集到另一个Observable而不是集合中，并发出那些Observables而不是集合。在下面的示例中，我们创建了一个Observable来发出9个项目，并使用window运算符将3个Observable一起发出。加窗示例使用您选择的任何编辑器(例如，C：\> RxJava)创建以下Java程序。Observa...