Lines Matching refs:chunk
413 var readChunk = function readChunk(chunk) {
417 if (chunk.done) {
426 var data = chunk.value;
1910 var chunk = bytes.subarray(i, chunkEnd);
1911 strBuf.push(String.fromCharCode.apply(null, chunk));
7228 value: function write(chunk) {
7237 return WritableStreamDefaultWriterWrite(this, chunk);
7383 function WritableStreamDefaultWriterWrite(writer, chunk) {
7387 var chunkSize = WritableStreamDefaultControllerGetChunkSize(controller, chunk);
7409 WritableStreamDefaultControllerWrite(controller, chunk, chunkSize);
7490 function WritableStreamDefaultControllerGetChunkSize(controller, chunk) {
7498 return strategySize(chunk);
7509 function WritableStreamDefaultControllerWrite(controller, chunk, chunkSize) {
7511 chunk: chunk
7574 WritableStreamDefaultControllerProcessWrite(controller, writeRecord.chunk);
7597 function WritableStreamDefaultControllerProcessWrite(controller, chunk) {
7600 …var sinkWritePromise = PromiseInvokeOrNoop(controller._underlyingSink, 'write', [chunk, controller…
8428 function ReadableStreamFulfillReadIntoRequest(stream, chunk, done) {
8434 readIntoRequest._resolve(CreateIterResultObject(chunk, done));
8437 function ReadableStreamFulfillReadRequest(stream, chunk, done) {
8443 readRequest._resolve(CreateIterResultObject(chunk, done));
8788 value: function enqueue(chunk) {
8803 return ReadableStreamDefaultControllerEnqueue(this, chunk);
8832 var chunk = DequeueValue(this);
8840 return Promise.resolve(CreateIterResultObject(chunk, false));
8942 function ReadableStreamDefaultControllerEnqueue(controller, chunk) {
8948 ReadableStreamFulfillReadRequest(stream, chunk, false);
8956 chunkSize = strategySize(chunk);
8964 EnqueueValueWithSize(controller, chunk, chunkSize);
9118 value: function enqueue(chunk) {
9133 if (!ArrayBuffer.isView(chunk)) {
9137 ReadableByteStreamControllerEnqueue(this, chunk);
9598 function ReadableByteStreamControllerEnqueue(controller, chunk) {
9602 var buffer = chunk.buffer;
9603 var byteOffset = chunk.byteOffset;
9604 var byteLength = chunk.byteLength;
9836 function TransformStreamEnqueueToReadable(transformStream, chunk) {
9848 ReadableStreamDefaultControllerEnqueue(controller, chunk);
9933 function TransformStreamDefaultTransform(chunk, transformStreamController) {
9935 TransformStreamEnqueueToReadable(transformStream, chunk);
9939 function TransformStreamTransform(transformStream, chunk) {
9946 …keOrPerformFallback(transformer, 'transform', [chunk, controller], TransformStreamDefaultTransform…
9999 value: function write(chunk) {
10001 return TransformStreamTransform(transformStream, chunk);
10099 value: function enqueue(chunk) {
10104 TransformStreamEnqueueToReadable(this._controlledTransformStream, chunk);
11390 value: function sendProgressiveData(chunk) {
11610 value: function sendProgressiveData(chunk) {
11612 chunk: chunk
11678 for (var chunk = 0, n = this.numChunks; chunk < n; ++chunk) {
11679 if (!this.loadedChunks[chunk]) {
11680 chunks.push(chunk);
11698 value: function onReceiveData(begin, chunk) {
11705 var end = begin + chunk.byteLength;
11711 this.bytes.set(new Uint8Array(chunk), begin);
11746 var chunk = Math.floor(pos / this.chunkSize);
11748 if (chunk === this.lastSuccessfulEnsureByteChunk) {
11752 if (!this.loadedChunks[chunk]) {
11756 this.lastSuccessfulEnsureByteChunk = chunk;
11773 for (var chunk = beginChunk; chunk < endChunk; ++chunk) {
11774 if (!this.loadedChunks[chunk]) {
11785 var chunk = (beginChunk + i) % numChunks;
11787 if (!this.loadedChunks[chunk]) {
11788 return chunk;
11796 value: function hasChunk(chunk) {
11797 return !!this.loadedChunks[chunk];
11918 for (var chunk = beginChunk; chunk < endChunk; ++chunk) {
11919 if (!this.loadedChunks[chunk]) {
11920 missingChunks.push(chunk);
11990 var readChunk = function readChunk(chunk) {
11992 if (!chunk.done) {
11993 var data = chunk.value;
12023 chunk: data,
12078 for (var chunk in chunksNeeded) {
12079 chunk = chunk | 0;
12081 if (!(chunk in this.requestsByChunk)) {
12082 this.requestsByChunk[chunk] = [];
12083 chunksToRequest.push(chunk);
12086 this.requestsByChunk[chunk].push(requestId);
12135 for (var chunk = beginChunk; chunk < endChunk; ++chunk) {
12136 chunks.push(chunk);
12156 for (var chunk = beginChunk; chunk < endChunk; ++chunk) {
12157 if (!chunksToRequest.includes(chunk)) {
12158 chunksToRequest.push(chunk);
12190 var chunk = chunks[i];
12193 beginChunk = chunk;
12196 if (prevChunk >= 0 && prevChunk + 1 !== chunk) {
12201 beginChunk = chunk;
12207 endChunk: chunk + 1
12211 prevChunk = chunk;
12227 var chunk = args.chunk;
12230 var end = begin + chunk.byteLength;
12235 this.stream.onReceiveProgressiveData(chunk);
12238 this.stream.onReceiveData(begin, chunk);
17411 var chunk = stream.getBytes();
17413 var newLength = bufferLength + chunk.length;
17415 buffer.set(chunk, bufferLength);
17994 var chunk;
17997 chunk = this.nextChunk;
17999 chunk = this.str.getBytes(chunkSize);
18003 if (!chunk || chunk.length === 0) {
18011 chunk = decrypt(chunk, !hasMoreData);
18014 n = chunk.length;
18018 buffer[bufferLength++] = chunk[i];
20604 var chunk = chunks[i];
20605 var segments = readSegments({}, chunk.data, chunk.start, chunk.end);
24551 var chunk = dataItem.data.subarray(dataItem.start, dataItem.end);
24552 encodedData.set(chunk, position);
24553 position += chunk.length;
32164 enqueue: function enqueue(chunk, size) {
32166 sink.enqueue(chunk, size);
55713 chunk = _ref.chunk,
55723 chunk: chunk,
55730 enqueue: function enqueue(chunk) {
55748 chunk: chunk,
55868 this.streamControllers[data.streamId].controller.enqueue(data.chunk);