Извлечение данных из ReadableStream с помощью Fetch API

const reader = stream.getReader();
let chunks = [], decoder = new TextDecoder();

reader.read().then(function processData({ done, value }) {
  if (done) {
    console.log('Поток завершён, все фрагменты данных получены', decoder.decode(concat(chunks)));
    return;
  }
  chunks.push(value);
  reader.read().then(processData);
});

function concat(chunks) { // Объединяем части в одно целое
  return chunks.reduce((acc, chunk) => new Uint8Array([...acc, ...chunk]), new Uint8Array());
}

fetch('https://api.example.com/data')
  .then(response => response.json()) // Преобразуем ответ в JSON
  .then(data => console.log(data))
  .catch(error => console.error('Произошла ошибка:', error));

// Обработка данных в формате, отличном от JSON
fetch('https://api.example.com/data')
  .then(response => response.text()) // Получаем текстовую информацию
  .then(text => console.log(text))
  .catch(error => console.error('Произошла ошибка:', error));

// Работа с бинарными данными
fetch('https://api.example.com/binary-data')
  .then(response => response.arrayBuffer()) // Получаем массив байт
  .then(buffer => console.log(new Uint8Array(buffer)))
  .catch(error => console.error('Произошла ошибка:', error));

async function streamToString(stream) {
  const reader = stream.getReader();
  const decoder = new TextDecoder(); // Наш помощник — декодер
  let result = '';

  while (true) {
    const { done, value } = await reader.read();
    if (done) break;
    result += decoder.decode(value, { stream: true });
  }
  result += decoder.decode(); // Финальный шаг для получения данных
  return result;
}

streamToString(yourReadableStream)
  .then(str => JSON.parse(str))
  .then(data => console.log('Данные получены:', data))
  .catch(error => console.error('Ошибка при обработке данных:', error));

fetch('https://api.example.com/data').then(response => {
  if (!response.ok) {
    throw new Error('Сервер вернул некорректный ответ');
  }
  return response.json();
})
.catch(error => {
  console.error('Произошла ошибка при запросе данных:', error);
});

const reader = stream.getReader();

reader.read().then(({ value, done }) => {
  if (done) {
    console.log("Поток завершён. Данные собраны!");
  } else {
    console.log(`Получена новая порция данных:`, value);
  }
});

reader.cancel(); // Прерываем чтение данных из потока.