在参数中访问自定义RxJS运算符中的流变量

import { Observable } from 'rxjs';

// 自定义运算符函数
function customOperator(variable) {
  // 返回一个函数作为实际的运算符
  return function(source) {
    return new Observable(observer => {
      source.subscribe({
        next(value) {
          // 在闭包内部访问流变量
          console.log(`流的变量值为：${variable}`);
          // 对数据流进行操作
          const modifiedValue = value + variable;
          // 发送处理后的数据
          observer.next(modifiedValue);
        },
        error(err) {
          observer.error(err);
        },
        complete() {
          observer.complete();
        }
      });
    });
  };
}

// 使用自定义运算符
const source = new Observable(observer => {
  observer.next(1);
  observer.next(2);
  observer.complete();
});

const variable = 10;

source
  .pipe(customOperator(variable))
  .subscribe({
    next(value) {
      console.log(value); // 输出：11, 12
    },
    complete() {
      console.log('流处理完成');
    }
  });