如何在不将所有代码更改为promises的情况下等待可观察的rxjs

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

const observable = new Observable(observer => {
  // 在这里定义可观察对象的行为
  // 例如，使用observer.next(value)发送值
  // 使用observer.complete()表示可观察对象完成
});

const promise = observable.pipe(first()).toPromise();

async function waitForObservable() {
  try {
    const result = await promise;
    // 在这里处理可观察对象完成后的结果
  } catch (error) {
    // 在这里处理可观察对象发生的错误
  }
}

waitForObservable();

promise.then(
  result => {
    // 在这里处理可观察对象完成后的结果
  },
  error => {
    // 在这里处理可观察对象发生的错误
  }
);