如何在RxJS中调用一组操作？

import { Observable } from 'rxjs';
import { map, filter, switchMap } from 'rxjs/operators';

const dataStream = new Observable(observer => {
  // 在这里定义数据流的产生方式，比如从服务器获取数据
  // 当有新的数据产生时，调用observer.next(data)发送数据
  // 当数据流结束时，调用observer.complete()表示完成
  // 如果出现错误，调用observer.error(error)发送错误信息
});

dataStream.pipe(
  map(data => {
    // 在这里对数据进行转换或处理
    // 返回处理后的数据
  }),
  filter(data => {
    // 在这里根据条件过滤数据
    // 返回true表示保留数据，返回false表示丢弃数据
  }),
  switchMap(data => {
    // 在这里可以进行异步操作，比如发送HTTP请求
    // 返回一个新的Observable对象，用于处理异步操作的结果
  })
).subscribe(
  result => {
    // 在这里处理最终的结果
  },
  error => {
    // 在这里处理错误情况
  },
  () => {
    // 在这里处理数据流完成的情况
  }
);