Rxjs:如何在管道中绑定主题？

import { Subject } from 'rxjs';
import { tap } from 'rxjs/operators';

// 创建一个主题
const themeSubject = new Subject();

// 在管道中绑定主题
const dataStream = getData().pipe(
  tap(data => {
    // 发送数据到主题
    themeSubject.next(data.theme);
  })
);

// 订阅主题
themeSubject.subscribe(theme => {
  // 处理主题变化
  console.log('主题变化：', theme);
});

// 订阅数据流
dataStream.subscribe(data => {
  // 处理数据
  console.log('数据：', data);
});

// 获取数据的函数
function getData() {
  // 返回一个可观察对象
  return new Observable(observer => {
    // 模拟异步获取数据
    setTimeout(() => {
      observer.next({ theme: 'dark' });
      observer.complete();
    }, 1000);
  });
}