我应该如何编写我的单次运行RxJs代码，以便可以针对订阅泄漏进行测试？

import { Observable, Subscription } from 'rxjs';
import { takeUntil } from 'rxjs/operators';

const myObservable = new Observable(observer => {
  // 在这里定义需要执行的操作
  // 例如，发送HTTP请求或执行一些计算
  // 当操作完成时，调用observer的next、error或complete方法
});

const subscription = myObservable.subscribe(
  data => {
    // 处理接收到的数据
  },
  error => {
    // 处理错误情况
  },
  () => {
    // 处理完成情况
  }
);

const destroy$ = new Subject(); // 创建一个销毁信号
myObservable.pipe(takeUntil(destroy$)).subscribe(/* ... */); // 使用takeUntil操作符

destroy$.next(); // 手动触发销毁信号
destroy$.complete(); // 告诉Observable销毁信号已完成