rxjs:使用rxjs自定义操作符更改HttpRequest

import { Observable } from 'rxjs';
import { map } from 'rxjs/operators';

// 自定义操作符，用于修改HttpRequest
function modifyHttpRequest() {
  return function (source) {
    return new Observable((observer) => {
      // 在这里对HttpRequest进行修改
      const modifiedRequest = source.request.clone({
        // 修改请求头等参数
      });

      // 发送修改后的HttpRequest
      const subscription = source.subscribe({
        next: (response) => {
          // 在这里对HttpResponse进行修改
          const modifiedResponse = response.clone({
            // 修改响应体等参数
          });

          // 发送修改后的HttpResponse
          observer.next(modifiedResponse);
        },
        error: (error) => {
          observer.error(error);
        },
        complete: () => {
          observer.complete();
        }
      });

      // 返回取消订阅的函数
      return () => {
        subscription.unsubscribe();
      };
    });
  };
}

// 使用自定义操作符修改HttpRequest
const modifiedRequest$ = httpRequest$.pipe(
  modifyHttpRequest()
);

// 订阅修改后的HttpRequest
modifiedRequest$.subscribe((response) => {
  // 处理修改后的HttpResponse
});