Function processTransformResultAsync

src/pull.ts:215–273

* Process transform result (async).

(
  result: AsyncTransformResult
)

/**
 * Process transform result (async).
 */
async function* processTransformResultAsync(
  result: AsyncTransformResult
): AsyncGenerator<Uint8Array[]> {
  // Handle Promise
  if (result instanceof Promise) {
    const resolved = await result;
    yield* processTransformResultAsync(resolved);
    return;
  }
  if (result === null) {
    return;
  }
  if (Array.isArray(result) && (result.length === 0 || result[0] instanceof Uint8Array)) {
    // Fast path: Uint8Array[]
    if (result.length > 0) {
      yield result as Uint8Array[];
    }
    return;
  }
  // Check for async iterable/generator first
  if (isAsyncIterable(result)) {
    const batch: Uint8Array[] = [];
    for await (const item of result) {
      // Fast path: item is already Uint8Array
      if (item instanceof Uint8Array) {
        batch.push(item);
        continue;
      }
      // Slow path: flatten the item
      for await (const chunk of flattenTransformYieldAsync(item as TransformYield)) {
        batch.push(chunk);
      }
    }
    if (batch.length > 0) {
      yield batch;
    }
    return;
  }
  // Sync Iterable or Generator
  if (isSyncIterable(result)) {
    const batch: Uint8Array[] = [];
    for (const item of result) {
      // Fast path: item is already Uint8Array
      if (item instanceof Uint8Array) {
        batch.push(item);
        continue;
      }
      // Slow path: flatten the item
      for await (const chunk of flattenTransformYieldAsync(item as TransformYield)) {
        batch.push(chunk);
      }
    }
    if (batch.length > 0) {
      yield batch;
    }
    return;
  }