将基于回调的流转换为异步可迭代

问题描述

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

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

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

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）