for await()

in streaming.ts [253:274]

• 19 lines of code
• 6 McCabe index (conditional complexity)

  for await (const chunk of iterator) {
    if (chunk == null) {
      continue;
    }

    const binaryChunk = chunk instanceof ArrayBuffer
      ? new Uint8Array(chunk)
      : typeof chunk === "string"
      ? new TextEncoder().encode(chunk)
      : chunk;

    let newData = new Uint8Array(data.length + binaryChunk.length);
    newData.set(data);
    newData.set(binaryChunk, data.length);
    data = newData;

    let patternIndex;
    while ((patternIndex = findDoubleNewlineIndex(data)) !== -1) {
      yield data.slice(0, patternIndex);
      data = data.slice(patternIndex);
    }
  }