Spaces:
Running
Running
File size: 4,492 Bytes
78c921d |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 |
"use strict";
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
Object.defineProperty(exports, "__esModule", { value: true });
exports.BuilderTransform = exports.builderThroughDOMStream = void 0;
const tslib_1 = require("tslib");
const factories_js_1 = require("../../factories.js");
/** @ignore */
function builderThroughDOMStream(options) {
return new BuilderTransform(options);
}
exports.builderThroughDOMStream = builderThroughDOMStream;
/** @ignore */
class BuilderTransform {
constructor(options) {
// Access properties by string indexers to defeat closure compiler
this._numChunks = 0;
this._finished = false;
this._bufferedSize = 0;
const { ['readableStrategy']: readableStrategy, ['writableStrategy']: writableStrategy, ['queueingStrategy']: queueingStrategy = 'count' } = options, builderOptions = tslib_1.__rest(options, ['readableStrategy', 'writableStrategy', 'queueingStrategy']);
this._controller = null;
this._builder = (0, factories_js_1.makeBuilder)(builderOptions);
this._getSize = queueingStrategy !== 'bytes' ? chunkLength : chunkByteLength;
const { ['highWaterMark']: readableHighWaterMark = queueingStrategy === 'bytes' ? Math.pow(2, 14) : 1000 } = Object.assign({}, readableStrategy);
const { ['highWaterMark']: writableHighWaterMark = queueingStrategy === 'bytes' ? Math.pow(2, 14) : 1000 } = Object.assign({}, writableStrategy);
this['readable'] = new ReadableStream({
['cancel']: () => { this._builder.clear(); },
['pull']: (c) => { this._maybeFlush(this._builder, this._controller = c); },
['start']: (c) => { this._maybeFlush(this._builder, this._controller = c); },
}, {
'highWaterMark': readableHighWaterMark,
'size': queueingStrategy !== 'bytes' ? chunkLength : chunkByteLength,
});
this['writable'] = new WritableStream({
['abort']: () => { this._builder.clear(); },
['write']: () => { this._maybeFlush(this._builder, this._controller); },
['close']: () => { this._maybeFlush(this._builder.finish(), this._controller); },
}, {
'highWaterMark': writableHighWaterMark,
'size': (value) => this._writeValueAndReturnChunkSize(value),
});
}
_writeValueAndReturnChunkSize(value) {
const bufferedSize = this._bufferedSize;
this._bufferedSize = this._getSize(this._builder.append(value));
return this._bufferedSize - bufferedSize;
}
_maybeFlush(builder, controller) {
if (controller == null) {
return;
}
if (this._bufferedSize >= controller.desiredSize) {
++this._numChunks && this._enqueue(controller, builder.toVector());
}
if (builder.finished) {
if (builder.length > 0 || this._numChunks === 0) {
++this._numChunks && this._enqueue(controller, builder.toVector());
}
if (!this._finished && (this._finished = true)) {
this._enqueue(controller, null);
}
}
}
_enqueue(controller, chunk) {
this._bufferedSize = 0;
this._controller = null;
chunk == null ? controller.close() : controller.enqueue(chunk);
}
}
exports.BuilderTransform = BuilderTransform;
/** @ignore */ const chunkLength = (chunk) => { var _a; return (_a = chunk === null || chunk === void 0 ? void 0 : chunk.length) !== null && _a !== void 0 ? _a : 0; };
/** @ignore */ const chunkByteLength = (chunk) => { var _a; return (_a = chunk === null || chunk === void 0 ? void 0 : chunk.byteLength) !== null && _a !== void 0 ? _a : 0; };
//# sourceMappingURL=builder.js.map
|