如何在路由前等待subscribe事件完成

async function waitForSubscribe() {
  await new Promise((resolve) => {
    // 订阅事件
    eventEmitter.on('eventName', () => {
      // 异步操作完成后，调用resolve()来标识Promise完成
      resolve();
    });
  });
}

// 在路由导航前调用waitForSubscribe()函数
await waitForSubscribe();

import { Observable } from 'rxjs';

function waitForSubscribe() {
  return new Observable((observer) => {
    // 订阅事件
    eventEmitter.on('eventName', () => {
      // 异步操作完成后，通过next()方法发送一个值
      observer.next();
      // 完成后调用complete()方法
      observer.complete();
    });
  }).pipe(take(1)).toPromise();
}

// 在路由导航前调用waitForSubscribe()函数
await waitForSubscribe();