如何在链中将对象从`flatMap`传递到`subscribe`？

import { of } from 'rxjs';
import { flatMap } from 'rxjs/operators';

// 假设我们有一个源Observable，它发出一些对象
const source$ = of({ id: 1, name: 'Alice' }, { id: 2, name: 'Bob' });

// 使用flatMap来处理每个发出的对象
source$.pipe(
  flatMap(obj => {
    // 在这里进行对象的转换或处理
    // 例如，我们可以返回一个新的对象，包含原始对象和一个新的属性
    return of({ ...obj, processed: true });
  })
).subscribe(processedObj => {
  // 在subscribe回调中接收处理后的对象
  console.log(processedObj);
  // 输出将会是：
  // { id: 1, name: 'Alice', processed: true }
  // { id: 2, name: 'Bob', processed: true }
});

import { of } from 'rxjs';
import { flatMap, tap } from 'rxjs/operators';

const source$ = of({ id: 1, name: 'Alice' }, { id: 2, name: 'Bob' });

source$.pipe(
  tap(obj => console.log('Before flatMap:', obj)),
  flatMap(obj => {
    console.log('Inside flatMap:', obj);
    return of({ ...obj, processed: true });
  }),
  tap(processedObj => console.log('After flatMap:', processedObj))
).subscribe(processedObj => {
  console.log('In subscribe:', processedObj);
});