如何等待lambda函数的rxjs结果

const { Observable, Subject } = require('rxjs');

exports.handler = async (event, context, callback) => {
  const resultSubject = new Subject();

  const observable = new Observable((observer) => {
    // 执行异步操作，例如调用其他API或执行数据库查询
    // 在操作完成后，调用observer.next()发出结果
    // 如果出现错误，调用observer.error()发出错误信息
    // 最后，调用observer.complete()表示操作完成
    // 例如：
    setTimeout(() => {
      observer.next('Hello, world!');
      observer.complete();
    }, 1000);
  });

  observable.subscribe({
    next: (result) => {
      // 处理Observable返回的结果
      // 例如，将结果存储到数据库或返回给调用者
      console.log(result);
      resultSubject.next(result);
    },
    error: (error) => {
      // 处理Observable返回的错误
      console.error(error);
      resultSubject.error(error);
    },
    complete: () => {
      // 处理Observable的完成事件
      console.log('Observable completed');
      resultSubject.complete();
    }
  });

  // 等待Observable返回结果
  await new Promise((resolve, reject) => {
    resultSubject.subscribe({
      complete: resolve,
      error: reject
    });
  });

  // 在回调函数中处理Observable返回的结果
  resultSubject.subscribe({
    next: (result) => {
      // 执行相应的逻辑操作
      console.log(result);
    },
    error: (error) => {
      // 处理Observable返回的错误
      console.error(error);
    },
    complete: () => {
      // 处理Observable的完成事件
      console.log('Observable completed');
    }
  });

  // 返回结果给调用者
  callback(null, 'Observable completed');
};