如何在异步生成器函数中抛出错误

Question

在Javascript中的异步生成器函数中，第一个参数本身就是一个异步生成器函数，该函数用于转换函数。在函数中有一个转换和一个检查。如果检查不正确，应中止发电机功能。如果检查正确，则应得出结果。我用随机数模拟了误差。

我找到了三种抛出错误的方法：

• 返回Promise.reject（新的错误（一些消息）；
• 抛出新的错误（一些消息。）；
• 产生Promise.reject（新的错误（一些消息）；

export async function* transformAsync<T>(
    source: AsyncGenerator<T, void, unknown>,
) {
    for await (const line of source) {

        const transformedLine = transformWithSomeMagic(line);

        if(Math.random() > 0.8) {
            return Promise.reject(new Error("Some Message"));
            // OR
            throw new Error("Some Message.");
            // OR
            yield Promise.reject(new Error("Some Message"));
        }

        yield transformedLine;
    }
}

所有的结果都是相同的。我想知道区别在哪里，当使用streams作为源参数时是否存在泄漏，因为它们是兼容的。

Answer 1

是的，它们都一样。没有泄漏，所有泄漏都会关闭源迭代器（在迭代器上调用.return（））。

你应该使用简单的抛出新的错误（...）；显式抛出一个错误自己，其他形式是有用的，当你调用一个promise返回函数和工作与隐式的等待。

Answer 2

无论阉羊你扔或返回在一个循环中，迭代器将被关闭（无论阉羊是同步还是异步）。

从概念上讲，进一步执行异步生成器的结果表示为promise，返回和让步类似于解决方案，抛出类似于拒绝。现在，用另一个promise来解决一个promise将“压扁”它，因此promise。拒绝包装是多余的。[规格]

        return Promise.reject(new Error("Some Message"));
        // barely equals
        resolve(Promise.reject(new Error("Some Message"))

        throw new Error("Some Message.");
        // barely equals
        reject(new Error("Some Message."));

        yield Promise.reject(new Error("Some Message"));
        // this one's more complicated, but it also barely equals
        resolve(Promise.reject(new Error("Some Message")));