Урок 63 из 114 · 9 мин

Асинхронные итераторы

Асинхронные генераторы async function*, for await…of, протокол асинхронных итераторов, Symbol.asyncIterator и Array.fromAsync.

Поток заказов

Заказы приходят по одному. Хочу обрабатывать их по мере поступления.
Ника
Асинхронный генератор отдаёт значения со временем, а for await ждёт каждое.

Ключевое слово

async function*

Асинхронный генератор

Что это: Можно и await, и yield: отдаёт значения по мере готовности.
Зачем: Поток данных: страницы API, события.
Как: JavaScript
async function* queue() { for (const d of ["Блокнот", "Пенал"]) { await wait(100); yield d; } } for await (const d of queue()) console.log("Готов", d);
Так это работает

Ключевое слово

for await…of

Перебор с ожиданием

Что это: Ждёт каждое значение асинхронного (или обычного с промисами) перебираемого.
Зачем: Обработать поток по одному элементу.
Как: JavaScript
for await (const v of [Promise.resolve(1), 2]) console.log(v);
Так это работает

Понятие

Асинхронный протокол

next() возвращает промис

Что это: Асинхронный итератор — объект с методом next(), который возвращает промис { value, done }; получают его через [Symbol.asyncIterator]().
Зачем: Свои асинхронные источники данных.
Как: JavaScript
const it = { i: 0, next() { return Promise.resolve(this.i < 2 ? { value: this.i++, done: false } : { done: true }); }, [Symbol.asyncIterator]() { return this; } }; for await (const v of it) console.log(v);
Так это работает

Метод

next() · return() · throw()

Методы асинхронного генератора

Что это: Как у обычного генератора, но каждый возвращает промис.
Зачем: Остановить поток досрочно.
Как: JavaScript
async function* g() { yield 1; yield 2; } const it = g(); console.log(await it.next(), await it.return("стоп"));
Так это работает

Метод

Array.fromAsync()

Массив из асинхронного источника

Что это: Дожидается всех значений асинхронного перебираемого и возвращает промис массива.
Зачем: Собрать поток в массив.
Как: JavaScript
async function* g() { yield "Блокнот"; await wait(50); yield "Пенал"; } console.log(await Array.fromAsync(g()));
Так это работает

Ника
Данные приходят частями со временем — это асинхронный итератор, перебирай его for await.

Ваш ход

Задание

Очередь по одному

Напиши асинхронный генератор queue(orders): для каждого товара ждёт wait(30) и отдаёт ` ${d} обработан . Собери результат в done через Array.fromAsync внутри async function run()` и вызови её.

Все элементы обработаны по порядку — пока нет
Это асинхронный генератор — пока нет
Использован Array.fromAsync — пока нет

let done = [];
function queue(orders) {
  return orders;
}

let done = [];
function queue(orders) {
  return orders;
}

Результат обновляется при вводе

ПрактикаОбязательное задание

for await

Выберите один ответ.

Что делает for await (const x of source)?

Домашнее заданиеДля закрепления

Протокол