ReadableStream: метод from()

Статический метод ReadableStream.from() возвращает объект ReadableStream на основе предоставленного итерируемого или асинхронного итерируемого объекта.

Метод может быть использован для обертывания итерируемых и асинхронных итерируемых объектов в виде читаемых потоков, включая массивы, множества, массивы промисов, асинхронные генераторы, ReadableStreams, Node.js readable потоки и т.д.

anyIterable

Объект итерируемый или асинхронно итерируемый.

Объект ReadableStream.

TypeError

Выбрасывается, если переданный параметр не является итерируемым или асинхронно итерируемым объектом (не определяет метод [Symbol.iterator]() или [Symbol.asyncIterator]()). Также выбрасывается, если во время итерации результат следующего шага не является объектом или является промисом, который не разрешается в объект.

Этот пример демонстрирует, как преобразовать асинхронно итерируемый объект в ReadableStream, а затем, как этот поток может быть потреблен.

HTML

HTML состоит из единственного элемента <pre>, используемого для регистрации.

<pre id="log"></pre>

JavaScript

Код примера создаёт функцию log() для записи в элемент HTML журнала.

const logElement = document.getElementById("log");
function log(text) {
  logElement.innerText += `${text}\n`;
}

Затем он проверяет, поддерживается ли статический метод, и если нет, регистрирует результат.

if (!ReadableStream.from) {
  log("ReadableStream.from() is not supported");
}

Асинхронно итерируемый объект — это анонимная функция-генератор, которая возвращает значения 1, 2 и 3 при вызове три раза. Она передаётся в ReadableStream.from() для создания ReadableStream.

// Define an asynchronous iterator
const asyncIterator = (async function* () {
  yield 1;
  yield 2;
  yield 3;
})();

// Create ReadableStream from iterator
const myReadableStream = ReadableStream.from(asyncIterator);

Использование потоков чтения демонстрирует несколько способов потребления потока. Ниже используется цикл for ...await, так как этот метод является наиболее простым. В каждой итерации цикла регистрируется текущая часть из потока.

consumeStream(myReadableStream);

// Iterate a ReadableStream asynchronously
async function consumeStream(readableStream) {
  for await (const chunk of myReadableStream) {
    // Do something with each chunk
    // Here we just log the values
    log(`chunk: ${chunk}`);
  }
}

Результат

Вывод потребления потока показан ниже (если ReadableStream.from() поддерживается).

Этот пример демонстрирует, как преобразовать Array в ReadableStream.

JavaScript

Итерируемый объект — это просто массив строк, который передаётся в ReadableStream.from() для создания ReadableStream.

// An Array of vegetable names
const vegetables = ["Carrot", "Broccoli", "Tomato", "Spinach"];

// Create ReadableStream from the Array
const myReadableStream = ReadableStream.from(vegetables);

Мы используем тот же подход, что и в предыдущем примере, для логирования и потребления потока, поэтому он здесь не показан.

Результат

Вывод показан ниже.

• ReadableStream
• Использование потоков чтения