7

正在阅读新的 JS 运行时 deno 的主页

我看到了以下代码:

import { serve } from "https://deno.land/std@0.50.0/http/server.ts";
const s = serve({ port: 8000 });
console.log("http://localhost:8000/");
for await (const req of s) {
  req.respond({ body: "Hello World\n" });
}

我从未见过以下语法(for await):

for await (const req of s) {
  req.respond({ body: "Hello World\n" });
}

这种语法是什么?

它是 deno 特有的,还是这个 tc39 提案中的顶级等待?

编辑:为什么它可以在函数之外使用async

4

2 回答 2

12

for await...of语句用于遍历异步迭代器,并serve返回一个异步迭代器,其中每次迭代将是一个新的传入请求。

它是 deno 特有的,还是这个 tc39 提案中的顶级等待?

不,它不是针对 Deno 的,它是一个不同于top-level await.


这是一个asyncIterator在浏览器中也可以使用的简单示例(非 deno 独占)

const obj = {
   async *[Symbol.asyncIterator]() {
      for(let i = 0; i < 10; i++)
        yield new Promise(resolve => setTimeout(() => resolve(i), 100));
   }
};

(async() => {
  // You don't need the wrapper if the environment 
  // supports top-level await, e.g: Deno
  for await(const i of obj)
    console.log(`${i}`, new Date())

})();


编辑:为什么它可以在异步函数之外使用?

因为 Deno 支持top-level await

于 2020-05-20T15:25:26.113 回答
1

当我决定使用 Deno 时,这也引起了我的注意。我喜欢 Deno,因为它在 ES6 上是原生的,比如 Promises、Import - Export,而且你甚至不需要像 Node 中那样的 npm,只需要import来自 url 的包。

现在,为了简化代码,这个asyncawait抽象是可以的,但它也隐藏了很多东西,有些人基本上很难理解到底发生了什么。

我首先建议您花点时间阅读这篇关于异步迭代的精美文章

问题是,在启动服务器的非常基本的代码中,

import { serve } from "https://deno.land/std@0.87.0/http/server.ts";
const s = serve({ port: 8000 });
console.log("http://127.0.0.1:8000/");

for await (const req of s) {
  req.respond({ body: "Hello World\n" });
}

您必须接受,由于某种原因for await,当收到请求时,循环会转动一次。实际上,这正是它的作用。驱动异步迭代和承诺的机器是隐藏的。

现在我们应该知道了s

const s = serve({ port: 8000 });

实际上是一个异步可迭代对象。所以它有一个方法叫做[Symbol.asyncIterator]. 当您调用它时,就像s[Symbol.asyncIterator]()您获得带有next方法的异步迭代器对象一样。next()通常在调用时使用同步迭代器会收到类似的对象,{value: "stg", done: false}但在异步迭代器Promise中会收到 a 。这个承诺,一旦收到请求时解决(或者如果发生错误则拒绝)给我们一个像

{ value: ServerRequest Object 
, done : false
}

所以上面的代码也可以这样写;

import { serve } from "https://deno.land/std@0.87.0/http/server.ts";
const s = serve({ port: 8000 });
console.log("http://127.0.0.1:8000/");

var rqs = s[Symbol.asyncIterator](),
    srv = (app,rqs) => rqs.next().then(rq => (app(rq.value), srv(app,rqs))),
    app = req => req.respond({body: "Hello World\n"});

srv(app,rqs); // receive requests and handle them with your app
于 2021-02-13T17:27:37.417 回答