RxJS教程

本章介绍有关RxJS的功能，优点和缺点的信息。在这里，我们还将学习何时使用RxJS。 RxJS的完整形式是Java的Reactive Extension。这是一个JavaScrip…

在本章中，我们将安装RxJS。要使用RxJS，我们需要以下设置- NodeJS Npm RxJS package installation NODEJS和NPM安装 使用npm安装…

在本教程中，我们将使用RxJS版本6。RxJS通常用于处理反应式编程，并且在Angular，ReactJS中更常使用。Angular 6默认情况下会加载rxjs6。 与版本6相比，…

observable是创建观察者并将其附加到源的源函数，例如，单击，来自dom元素或Http请求的鼠标事件等期望值的源。 Observer是具有回调函数的对象，当与Observab…

运算符是RxJS的重要组成部分。运算符是一个纯函数，它以可观察值作为输入，而输出也是可观察的。 运算符 运算符是一个纯函数，它以可观察的输入作为输入，而输出也是可观察的。 要与运算…

如果有错误，此操作员将尝试在源Observable上重试，并且将根据给定的输入计数进行重试。 语法 retry(retry_count: number): Observable 参…

该运算符负责通过返回新的Observable或错误来在源Observable上捕获错误。 语法 catchError(selector_func: (err_func: any, …

它是multicast()运算符的别名，唯一的区别是您不必手动调用connect()方法即可启动订阅。 语法 share() 例 import { interval} from ‘…

publishReplay利用行为主题，其中，它可以缓冲值并将其重放给新订阅者，并返回ConnectableObservable。connect()方法必须用于订阅创建的可观察对象…

publishBehaviour使用AsyncSubject，并返回ConnectableObservable。connect()方法必须用于订阅创建的可观察对象。 例 impor…

publishBehaviour使用BehaviourSubject，并返回ConnectableObservable。connect()方法必须用于订阅创建的可观察对象。 语法 …

publish()运算符返回ConnectableObservable，并且需要使用connect()方法订阅可观察对象。 语法 publish() 例 import { inte…

Multicasting运算符与其他订阅者共享创建的单个订阅。组播接受的参数是返回必须具有connect()方法的ConnectableObservable的主题或工厂方法。要订阅…

如果输入observable进行完整的回调而不发出任何值，则此运算符将输出为true；如果输入observable发出任何值，则该运算符将为false。 句法 isEmpty():…

该运算符将为您提供来自源Observable的第一个值的索引，该索引恰好满足谓词函数中的条件。 句法 findIndex(predicate_func: function): Ob…

当源Observable的第一个值满足作为输入的谓词函数的条件时，将返回observable。 句法 find(predicate_func: function): Observa…

它将基于输入函数返回一个Observable，该输入函数满足源Observable上每个值的条件。 句法 every(predicate_func: function): Obse…

如果源可观察项为空，则此运算符将返回默认值。 句法 defaultIfEmpty(defaultValue = null): Observable 参量 defaultValue-…

累积来自Observable的所有源值，并在源完成时将它们输出为数组。 句法 toArray():Observable 返回值 返回一个observable，当源完成时，将源obs…

如果源Observable在给定的超时后未发出值，则此运算符将引发错误。 句法 timeout(timeout: number | Date): Observable 参量 tim…