Verarbeitung von ReadableStream-Antwort-Chunks über benutzerdefinierte asynchrone Iteratoren

export async function* streamChunks(response) {
  const reader = response.body.getReader();
  const decoder = new TextDecoder();
  try {
    while (true) {
      const { done, value } = await reader.read();
      if (done) break;
      yield decoder.decode(value, { stream: true });
    }
  } finally {
    reader.releaseLock();
  }
}
 
export async function consumeStreamInSvelte(response, onChunk) {
  for await (const chunk of streamChunks(response)) {
    onChunk(chunk);
  }
}