ReadableStreamDefaultController: метод close()

Метод close() интерфейса ReadableStreamDefaultController закрывает связанный поток.

Читатели всё ещё смогут прочитать все ранее поставленные в очередь куски данных из потока, но как только эти данные будут прочитаны, поток станет закрытым. Если вы хотите полностью избавиться от потока и отбросить все поставленные в очередь куски данных, используйте ReadableStream.cancel() или ReadableStreamDefaultReader.cancel().

Нет.

Нет (undefined).

TypeError

Выбрасывается, если close() вызывается, когда поток не читается — потому что он уже закрыт, отменён или содержит ошибку — или потому что подлежащий источник запросил его закрытие, но пока не выполнил это, так как ещё есть куски данных в очереди для чтения.

В следующем простом примере создаётся пользовательский ReadableStream с помощью конструктора (см. наш пример простого случайного потока для полного кода). Функция start() генерирует случайную строку текста каждую секунду и ставит её в очередь в поток. Также предоставляется функция cancel(), которая останавливает генерацию, если вызывается ReadableStream.cancel() по какой-либо причине.

При нажатии кнопки генерация останавливается, поток закрывается с помощью close(), и выполняется другая функция, которая считывает данные из потока.

let interval;
const stream = new ReadableStream({
  start(controller) {
    interval = setInterval(() => {
      let string = randomChars();

      // Add the string to the stream
      controller.enqueue(string);

      // show it on the screen
      let listItem = document.createElement("li");
      listItem.textContent = string;
      list1.appendChild(listItem);
    }, 1000);

    button.addEventListener("click", () => {
      clearInterval(interval);
      fetchStream();
      controller.close();
    });
  },
  pull(controller) {
    // We don't really need a pull in this example
  },
  cancel() {
    // This is called if the reader cancels,
    // so we should stop generating strings
    clearInterval(interval);
  },
});

• Использование читаемых потоков
• ReadableStreamDefaultController