Function pipeToSync

src/pull.js:1189–1234

* Write a sync source through transforms to a sync writer. * * @param source - The sync source yielding Uint8Array[] batches * @param args - Variadic transforms, writer (required), and optional options * @returns Total bytes written

(source)

 * @returns Total bytes written
 */
function pipeToSync(source) {
    var _a;
    var args = [];
    for (var _i = 1; _i < arguments.length; _i++) {
        args[_i - 1] = arguments[_i];
    }
    var _b = parsePipeToArgs(args), transforms = _b.transforms, writer = _b.writer, options = _b.options;
    // Handle transform-writer: if writer has transform, apply it as last transform
    var finalTransforms = __spreadArray([], transforms, true);
    if (isTransformObject(writer)) {
        finalTransforms.push(writer);
    }
    // Create pipeline
    var pipeline = finalTransforms.length > 0
        ? createSyncPipeline((_a = {}, _a[Symbol.iterator] = function () { return source[Symbol.iterator](); }, _a), finalTransforms)
        : source;
    var totalBytes = 0;
    try {
        for (var _c = 0, pipeline_1 = pipeline; _c < pipeline_1.length; _c++) {
            var batch = pipeline_1[_c];
            for (var _d = 0, batch_1 = batch; _d < batch_1.length; _d++) {
                var chunk = batch_1[_d];
                totalBytes += chunk.byteLength;
            }
            if ('writev' in writer && typeof writer.writev === 'function') {
                writer.writev(batch);
            }
            else {
                for (var _e = 0, batch_2 = batch; _e < batch_2.length; _e++) {
                    var chunk = batch_2[_e];
                    writer.write(chunk);
                }
            }
        }
        if (!(options === null || options === void 0 ? void 0 : options.preventClose)) {
            writer.end();
        }
    }
    catch (error) {
        if (!(options === null || options === void 0 ? void 0 : options.preventFail)) {
            writer.fail(error);
        }
        throw error;
    }
    return totalBytes;
}
/**
 * Write an async source through transforms to a writer.
 *