ReadableStreamDefaultReader

Интерфейс ReadableStreamDefaultReader API потоков представляет собой стандартный читатель, который можно использовать для чтения данных потока, поступающих из сети (например, при запросе fetch).

ReadableStreamDefaultReader можно использовать для чтения из ReadableStream, имеющего базовый источник любого типа (в отличие от ReadableStreamBYOBReader, который можно использовать только с потоками чтения, имеющими базовый байтовый источник).

Однако следует отметить, что передача без копирования из базового источника поддерживается только для базовых байтовых источников, которые автоматически выделяют буферы. Другими словами, поток должен быть создан, указав как type="bytes", так и autoAllocateChunkSize. Для любого другого базового источника поток всегда будет удовлетворять запросам чтения данными из внутренних очередей.

ReadableStreamDefaultReader()

Создаёт и возвращает экземпляр объекта ReadableStreamDefaultReader.

ReadableStreamDefaultReader.closed Только для чтения

Возвращает Promise, который выполняется при закрытии потока или отклоняется, если поток выбросит ошибку или блокировка читателя будет освобождена. Это свойство позволяет вам написать код, реагирующий на завершение процесса потоковой передачи.

ReadableStreamDefaultReader.cancel()

Возвращает Promise, который разрешается при отмене потока. Вызов этого метода сигнализирует о потере интереса потребителя к потоку. Переданное reason значение будет передано базовому источнику, который может или не может его использовать.

ReadableStreamDefaultReader.read()

Возвращает промис, обеспечивающий доступ к следующему фрагменту в внутренней очереди потока.

ReadableStreamDefaultReader.releaseLock()

Освобождает блокировку читателя на потоке.

В следующем примере создаётся искусственный Response, который передает фрагменты HTML, извлеченные из другого ресурса, браузеру.

Он демонстрирует использование ReadableStream в сочетании с Uint8Array.

fetch("https://www.example.org/").then((response) => {
  const reader = response.body.getReader();
  const stream = new ReadableStream({
    start(controller) {
      // The following function handles each data chunk
      function push() {
        // "done" is a Boolean and value a "Uint8Array"
        return reader.read().then(({ done, value }) => {
          // Is there no more data to read?
          if (done) {
            // Tell the browser that we have finished sending data
            controller.close();
            return;
          }

          // Get the data and send it to the browser via the controller
          controller.enqueue(value);
          push();
        });
      }

      push();
    },
  });

  return new Response(stream, { headers: { "Content-Type": "text/html" } });
});

• Основные понятия API потоков
• Использование потоков чтения
• ReadableStream
• Визуализатор потоков WHATWG, для базовой визуализации потоков чтения, записи и преобразования.
• Web-streams-polyfill или sd-streams — полифилы