我们的应用中的 RxJS 闪卡示例

从App Store或Google Play下载我们的应用程序，获取更多免费的闪卡，或订阅以访问所有的闪卡。

什么是RxJS？

JavaScript的响应式扩展，也被称为RxJS，是一个用于JavaScript的响应式编程库。RxJS实现了观察者设计模式，并通过提供事件流，允许复杂的异步操作和回调处理。

RxJS提供了名为Observables的数据结构，实际上是可以被“观察”的信息流。观察者可以订阅这些流并响应从它们流出的信息。

RxJS库的主要目标是协助管理应用程序中的异步操作和事件。它允许透明地管理数据流，从而简化经常使用常规回调或承诺时容易产生混乱的工作代码。

RxJS通常与其他库或前端框架（如Angular或React）一同使用。它的受欢迎程度也归因于其对许多运算符的支持，这些运算符允许对数据流进行过滤、分组、修改和许多其他操作。

Observable 和 Promise 之间有什么区别？

Observable和Promise是在JavaScript中表示异步操作的两种不同方式。

一个Promise是一个在未来返回单个值的对象。在创建Promise对象的时候，操作已经在运行并且无法停止。Promise可以处于以下三种状态之一：待定、已完成或已拒绝。

let promise = new Promise((resolve, reject) => {
  setTimeout(() => {
    resolve('Promise completed');
  }, 2000);
});

promise.then(result => console.log(result)); 
// 2 秒后，控制台将显示 'Promise completed'

另一方面，RxJS中的Observable可以在任何时候返回多个值，甚至是无限数量的值。订阅Observable会开始操作，可以使用unsubscribe()方法停止此操作。

let observable = new Observable(observer => {
  setTimeout(() => {
    observer.next('First callback');
    setTimeout(() => {
      observer.next('Second callback');
      observer.complete();
    }, 2000);
  }, 2000);
});

let subscription = observable.subscribe(result => console.log(result)); 
// 2 秒后，控制台将显示 'First callback'
// 又过了 2 秒，控制台将显示 'Second callback'
// 在任何时候，您都可以使用 'subscription.unsubscribe();' 停止观察

总的来说，Observable和Promise之间的主要区别之一是Observable是'懒惰的'，这意味着Observable对象在被订阅之前不会执行操作，而Promise在被创建后立即开始执行操作。另一个重要的区别是可以取消Observable的观察，而Promise则不可能。

请列举一些 RxJS 中的基本运算符。

RxJS提供了许多有用的运算符，允许修改数据流，对变化进行反应等。以下是其中的一些：

1. map() - 转换来自观察流的数据。

2. filter() - 允许根据特定标准筛选来自可观察的数据。

3. tap() - 用于调用副作用。

4. take() 和 first() - 从观察流中获取特定数量的值。

5. debounceTime() 和 throttleTime() - 允许在特定时间框架内限制发出的值的数量，这在响应鼠标移动或键入文本字段时非常有用。

6. catchError() - 允许处理观察源抛出的异常。

7. switchMap() 和 mergeMap() - 允许将每个发出的值映射到一个可观察的，然后可以与流合并。

8. combineLatest() - 允许从不同源组合流。

9. of() 和 from() - 这些运算符允许从不同类型的数据中创建可观察的，例如数组，Promises，可迭代的等等。

这些只是基本运算符，但RxJS提供了更多可能性。每个运算符都有其特性并在不同的场景中有用。

RxJS中有哪些类型的Subject？

在RxJs库中，我们可以使用四种类型的Subject：

1. 普通Subject - 这是Subject的基本类型。它只在发射时和之后的时候向观察者发射值。先前发射的值对新的订阅者是不可用的。

let subject = new Subject();
subject.next(1); // 将不会被任何观察者接收
subject.subscribe((value) => console.log(value)); // 订阅未来的发射
subject.next(2); // 将打印 '2'

2. 行为Subject - 存储最后发射的值，并在订阅时立即向新的订阅者提供。它必须初始化一个初始值。

let subject = new BehaviorSubject(1); // 使用值 '1' 进行初始化
subject.subscribe((value) => console.log(value)); // 订阅后立即打印 '1'
subject.next(2); // 将打印 '2'

3. 回放Subject - 你可以指定它应该存储和传递给观察者的最后几个值。它存储时间信息，因此我们可以访问特定的数据，例如一分钟前的数据。

let subject = new ReplaySubject(2); // 将存储最后2个值
subject.next(1);
subject.next(2);
subject.next(3);
subject.subscribe((value) => console.log(value)); // 将打印 '2', '3'

4. 异步Subject - 只有当Subject操作完成时才发射最后的值。

let subject = new AsyncSubject(); // 将只发射最后的值并且只在完成时发射
subject.next(1);
subject.next(2);
subject.subscribe((value) => console.log(value)); // 还不会打印任何东西
subject.next(3);
subject.complete(); // 由于操作已完成，将发射最后的值。将打印 '3'

RxJS 闪卡

我们的应用中的 RxJS 闪卡示例

什么是RxJS？

Observable 和 Promise 之间有什么区别？

请列举一些 RxJS 中的基本运算符。

RxJS中有哪些类型的Subject？

下载 IT 闪卡 立即

下载 IT 闪卡立即