RxJS的API调用序列 - Javascript

RxJS是一个基于观察者模式的JavaScript库，它让开发者更容易地编写异步和基于事件的程序。RxJS的api调用序列可以帮助开发者更好地理解和使用RxJS的功能。

创建Observables

首先，我们需要创建一个Observable。通过RxJS提供的Observable.create函数来创建Observable。以发送一段文本为例：

const observable = Rx.Observable.create(observer => {
  observer.next('Hello');
  observer.next('RxJS');
  observer.complete();
});

在上面的代码中，我们先通过调用Observable.create函数创建了一个Observable，然后在函数体内使用observer对象的next方法向下一个订阅者推送数据，并在数据完结时调用complete方法。

订阅Observables

接下来我们要订阅这个Observable，以便观察它的排放。通过调用Observable的subscribe方法来进行订阅：

const subscription = observable.subscribe(
  value => console.log(value),
  error => console.log(error),
  () => console.log('complete')
);

在上面的代码中，我们使用subscribe方法来订阅Observable，并传入3个回调函数，分别是：当Observable中有新数据时的回调函数、当Observable出现错误时的回调函数，以及当Observable发送完毕时的回调函数。最后，我们将订阅结果保存在subscription变量中，以便在之后需要时进行取消订阅。

取消Observables

有时候我们需要取消掉已经订阅的Observable。RxJS提供了Subscription类来管理订阅，我们可以调用subscription.unsubscribe()方法来取消Observable的订阅：

subscription.unsubscribe();

操作Observables

除此之外，RxJS还提供了一些操作符，用来对Observable流进行一些操作，比如转换数据、过滤数据、组合数据等等。

例如，我们可以使用map操作符将Observable中传递的数据进行映射：

const observable = Rx.Observable.create(observer => {
  observer.next('Hello');
  observer.next('RxJS');
  observer.complete();
});

const subscription = observable
  .map(value => value.toUpperCase())
  .subscribe(
    value => console.log(value),
    error => console.log(error),
    () => console.log('complete')
  );
// 输出：HELLO、RXJS、complete

在上面的代码中，我们使用map操作符将Observable的每个值都转换成大写字母后再进行观察。当我们订阅Observable时，就会输出所有大写字母的值。

除了map操作符，还有许多其他的操作符可供使用，开发者可以根据具体需要来选择使用。

结语

以上就是RxJS的api调用序列。通过创建Observables、订阅Observables、取消Observables以及操作Observables，开发者能够更好地利用RxJS来编写异步和基于事件的程序。