在Angular中创建数据流

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

const dataStream$ = new Observable(observer => {
  // 在这里可以进行异步操作，如从服务器获取数据
  // 当有新的数据可用时，通过调用observer.next(data)发送数据
  // 当数据流结束时，通过调用observer.complete()结束数据流
  // 如果发生错误，可以通过调用observer.error(error)发送错误信息
});

dataStream$
  .pipe(
    filter(data => data > 0), // 过滤数据，只保留大于0的值
    debounceTime(500), // 延迟500毫秒，以避免频繁触发
    map(data => data * 2) // 将数据乘以2
  )
  .subscribe(
    data => {
      // 处理转换后的数据
    },
    error => {
      // 处理错误信息
    },
    () => {
      // 数据流结束的处理
    }
  );