收到Rx编程秘籍！Observable，订阅与取消订阅，带你入门Rx编程

前端

2023-10-18 09:41:50

Observable是一种非常强大的工具，它可以用来构建各种各样的应用程序，从简单的UI到复杂的分布式系统。然而，Observable也可能很难理解，尤其是对于那些不熟悉函数式编程的人。

在本文中，我们将利用已有的知识去理解一个新的概念，利用高阶函数的思想去理解响应式编程中Observable的本质。通过讲解对Observable的订阅和取消订阅两个行为来帮助读者真正理解Observable是什么。

订阅Observable

订阅Observable是指将一个观察者对象与Observable关联起来，以便观察者对象可以接收Observable发出的数据。观察者对象可以是任何可以处理数据的对象，例如函数、类或对象。

订阅Observable可以通过多种方式进行。最简单的方法是使用Observable的subscribe()方法。subscribe()方法接受三个参数：

一个处理数据的函数。
一个处理错误的函数。
一个处理完成的函数。

例如，以下代码演示了如何订阅一个Observable并处理数据：

const observable = Rx.Observable.interval(1000);

observable.subscribe(
  (data) => {
    console.log(data);
  },
  (error) => {
    console.error(error);
  },
  () => {
    console.log("Completed");
  }
);

取消订阅Observable

取消订阅Observable是指将观察者对象与Observable分离，以便观察者对象不再接收Observable发出的数据。

取消订阅Observable可以通过多种方式进行。最简单的方法是使用Observable的unsubscribe()方法。unsubscribe()方法没有参数。

例如，以下代码演示了如何取消订阅一个Observable：

const observable = Rx.Observable.interval(1000);

const subscription = observable.subscribe(
  (data) => {
    console.log(data);
  },
  (error) => {
    console.error(error);
  },
  () => {
    console.log("Completed");
  }
);

subscription.unsubscribe();