Function flattenTransformYieldAsync

src/pull.ts:152–178

* Flatten transform yield to Uint8Array chunks (async).

(
  value: TransformYield | AsyncIterable<TransformYield>
)

/**
 * Flatten transform yield to Uint8Array chunks (async).
 */
async function* flattenTransformYieldAsync(
  value: TransformYield | AsyncIterable<TransformYield>
): AsyncGenerator<Uint8Array> {
  if (value instanceof Uint8Array) {
    yield value;
    return;
  }
  if (typeof value === 'string') {
    yield encoder.encode(value);
    return;
  }
  // Check for async iterable first
  if (isAsyncIterable(value)) {
    for await (const item of value) {
      yield* flattenTransformYieldAsync(item as TransformYield);
    }
    return;
  }
  // Must be sync Iterable<TransformYield>
  if (isSyncIterable(value)) {
    for (const item of value) {
      yield* flattenTransformYieldAsync(item as TransformYield);
    }
    return;
  }
  throw new TypeError(`Invalid transform yield type: ${typeof value}`);
}

/**