假设我有一些基于事件的流，例如“只读”websocket。通常设置“onmessage”回调来处理传入的消息。是否有某种方法可以访问异步迭代器中的消息？我的目标是

async () => {
    for await (const message of SOMETHING(new WebSocket('...'))) {
        // message is the content of the callback
    }
};

我曾经玩弄过承诺和队列，但是我找不到一种方法将回调（多次调用）转换为（异步）迭代器