如何停止rxjs中的共享

import { Observable, Subscription } from 'rxjs';

// 创建一个可观察对象
const observable = new Observable(observer => {
  // 执行可观察逻辑
  const intervalId = setInterval(() => {
    observer.next('Hello');
  }, 1000);

  // 返回一个取消订阅的函数
  return () => {
    clearInterval(intervalId);
  };
});

// 订阅可观察对象
const subscription = observable.subscribe(value => {
  console.log(value);
});

// 停止共享，取消订阅
subscription.unsubscribe();

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

// 创建一个Subject
const stopSignal$ = new Subject();

// 创建一个可观察对象
const observable = new Observable(observer => {
  // 执行可观察逻辑
  const intervalId = setInterval(() => {
    observer.next('Hello');
  }, 1000);

  // 返回一个取消订阅的函数
  return () => {
    clearInterval(intervalId);
  };
});

// 订阅可观察对象，并使用takeUntil操作符停止共享
observable.pipe(takeUntil(stopSignal$)).subscribe(value => {
  console.log(value);
});

// 发出停止信号，停止共享
stopSignal$.next();