Move the PredictorStream from src/core/stream.js and into its own file
This commit is contained in:
Jonas Jenwald
parent
e938c05edb
commit
66d9d83dcb
@ -33,7 +33,7 @@ import {
|
|||||||
Name,
|
Name,
|
||||||
Ref,
|
Ref,
|
||||||
} from "./primitives.js";
|
} from "./primitives.js";
|
||||||
import { FlateStream, NullStream, PredictorStream } from "./stream.js";
|
import { FlateStream, NullStream } from "./stream.js";
|
||||||
import { isWhiteSpace, MissingDataException } from "./core_utils.js";
|
import { isWhiteSpace, MissingDataException } from "./core_utils.js";
|
||||||
import { Ascii85Stream } from "./ascii_85_stream.js";
|
import { Ascii85Stream } from "./ascii_85_stream.js";
|
||||||
import { AsciiHexStream } from "./ascii_hex_stream.js";
|
import { AsciiHexStream } from "./ascii_hex_stream.js";
|
||||||
@ -42,6 +42,7 @@ import { Jbig2Stream } from "./jbig2_stream.js";
|
|||||||
import { JpegStream } from "./jpeg_stream.js";
|
import { JpegStream } from "./jpeg_stream.js";
|
||||||
import { JpxStream } from "./jpx_stream.js";
|
import { JpxStream } from "./jpx_stream.js";
|
||||||
import { LZWStream } from "./lzw_stream.js";
|
import { LZWStream } from "./lzw_stream.js";
|
||||||
|
import { PredictorStream } from "./predictor_stream.js";
|
||||||
import { RunLengthStream } from "./run_length_stream.js";
|
import { RunLengthStream } from "./run_length_stream.js";
|
||||||
|
|
||||||
const MAX_LENGTH_TO_CACHE = 1000;
|
const MAX_LENGTH_TO_CACHE = 1000;
|
||||||
|
|||||||
243
src/core/predictor_stream.js
Normal file
243
src/core/predictor_stream.js
Normal file
@ -0,0 +1,243 @@
|
|||||||
|
/* Copyright 2012 Mozilla Foundation
|
||||||
|
*
|
||||||
|
* Licensed 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.
|
||||||
|
*/
|
||||||
|
/* eslint-disable no-var */
|
||||||
|
|
||||||
|
import { DecodeStream } from "./stream.js";
|
||||||
|
import { FormatError } from "../shared/util.js";
|
||||||
|
import { isDict } from "./primitives.js";
|
||||||
|
|
||||||
|
var PredictorStream = (function PredictorStreamClosure() {
|
||||||
|
// eslint-disable-next-line no-shadow
|
||||||
|
function PredictorStream(str, maybeLength, params) {
|
||||||
|
if (!isDict(params)) {
|
||||||
|
return str; // no prediction
|
||||||
|
}
|
||||||
|
var predictor = (this.predictor = params.get("Predictor") || 1);
|
||||||
|
|
||||||
|
if (predictor <= 1) {
|
||||||
|
return str; // no prediction
|
||||||
|
}
|
||||||
|
if (predictor !== 2 && (predictor < 10 || predictor > 15)) {
|
||||||
|
throw new FormatError(`Unsupported predictor: ${predictor}`);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (predictor === 2) {
|
||||||
|
this.readBlock = this.readBlockTiff;
|
||||||
|
} else {
|
||||||
|
this.readBlock = this.readBlockPng;
|
||||||
|
}
|
||||||
|
|
||||||
|
this.str = str;
|
||||||
|
this.dict = str.dict;
|
||||||
|
|
||||||
|
var colors = (this.colors = params.get("Colors") || 1);
|
||||||
|
var bits = (this.bits = params.get("BitsPerComponent") || 8);
|
||||||
|
var columns = (this.columns = params.get("Columns") || 1);
|
||||||
|
|
||||||
|
this.pixBytes = (colors * bits + 7) >> 3;
|
||||||
|
this.rowBytes = (columns * colors * bits + 7) >> 3;
|
||||||
|
|
||||||
|
DecodeStream.call(this, maybeLength);
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
|
||||||
|
PredictorStream.prototype = Object.create(DecodeStream.prototype);
|
||||||
|
|
||||||
|
PredictorStream.prototype.readBlockTiff = function predictorStreamReadBlockTiff() {
|
||||||
|
var rowBytes = this.rowBytes;
|
||||||
|
|
||||||
|
var bufferLength = this.bufferLength;
|
||||||
|
var buffer = this.ensureBuffer(bufferLength + rowBytes);
|
||||||
|
|
||||||
|
var bits = this.bits;
|
||||||
|
var colors = this.colors;
|
||||||
|
|
||||||
|
var rawBytes = this.str.getBytes(rowBytes);
|
||||||
|
this.eof = !rawBytes.length;
|
||||||
|
if (this.eof) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
var inbuf = 0,
|
||||||
|
outbuf = 0;
|
||||||
|
var inbits = 0,
|
||||||
|
outbits = 0;
|
||||||
|
var pos = bufferLength;
|
||||||
|
var i;
|
||||||
|
|
||||||
|
if (bits === 1 && colors === 1) {
|
||||||
|
// Optimized version of the loop in the "else"-branch
|
||||||
|
// for 1 bit-per-component and 1 color TIFF images.
|
||||||
|
for (i = 0; i < rowBytes; ++i) {
|
||||||
|
var c = rawBytes[i] ^ inbuf;
|
||||||
|
c ^= c >> 1;
|
||||||
|
c ^= c >> 2;
|
||||||
|
c ^= c >> 4;
|
||||||
|
inbuf = (c & 1) << 7;
|
||||||
|
buffer[pos++] = c;
|
||||||
|
}
|
||||||
|
} else if (bits === 8) {
|
||||||
|
for (i = 0; i < colors; ++i) {
|
||||||
|
buffer[pos++] = rawBytes[i];
|
||||||
|
}
|
||||||
|
for (; i < rowBytes; ++i) {
|
||||||
|
buffer[pos] = buffer[pos - colors] + rawBytes[i];
|
||||||
|
pos++;
|
||||||
|
}
|
||||||
|
} else if (bits === 16) {
|
||||||
|
var bytesPerPixel = colors * 2;
|
||||||
|
for (i = 0; i < bytesPerPixel; ++i) {
|
||||||
|
buffer[pos++] = rawBytes[i];
|
||||||
|
}
|
||||||
|
for (; i < rowBytes; i += 2) {
|
||||||
|
var sum =
|
||||||
|
((rawBytes[i] & 0xff) << 8) +
|
||||||
|
(rawBytes[i + 1] & 0xff) +
|
||||||
|
((buffer[pos - bytesPerPixel] & 0xff) << 8) +
|
||||||
|
(buffer[pos - bytesPerPixel + 1] & 0xff);
|
||||||
|
buffer[pos++] = (sum >> 8) & 0xff;
|
||||||
|
buffer[pos++] = sum & 0xff;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
var compArray = new Uint8Array(colors + 1);
|
||||||
|
var bitMask = (1 << bits) - 1;
|
||||||
|
var j = 0,
|
||||||
|
k = bufferLength;
|
||||||
|
var columns = this.columns;
|
||||||
|
for (i = 0; i < columns; ++i) {
|
||||||
|
for (var kk = 0; kk < colors; ++kk) {
|
||||||
|
if (inbits < bits) {
|
||||||
|
inbuf = (inbuf << 8) | (rawBytes[j++] & 0xff);
|
||||||
|
inbits += 8;
|
||||||
|
}
|
||||||
|
compArray[kk] =
|
||||||
|
(compArray[kk] + (inbuf >> (inbits - bits))) & bitMask;
|
||||||
|
inbits -= bits;
|
||||||
|
outbuf = (outbuf << bits) | compArray[kk];
|
||||||
|
outbits += bits;
|
||||||
|
if (outbits >= 8) {
|
||||||
|
buffer[k++] = (outbuf >> (outbits - 8)) & 0xff;
|
||||||
|
outbits -= 8;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (outbits > 0) {
|
||||||
|
buffer[k++] =
|
||||||
|
(outbuf << (8 - outbits)) + (inbuf & ((1 << (8 - outbits)) - 1));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
this.bufferLength += rowBytes;
|
||||||
|
};
|
||||||
|
|
||||||
|
PredictorStream.prototype.readBlockPng = function predictorStreamReadBlockPng() {
|
||||||
|
var rowBytes = this.rowBytes;
|
||||||
|
var pixBytes = this.pixBytes;
|
||||||
|
|
||||||
|
var predictor = this.str.getByte();
|
||||||
|
var rawBytes = this.str.getBytes(rowBytes);
|
||||||
|
this.eof = !rawBytes.length;
|
||||||
|
if (this.eof) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
var bufferLength = this.bufferLength;
|
||||||
|
var buffer = this.ensureBuffer(bufferLength + rowBytes);
|
||||||
|
|
||||||
|
var prevRow = buffer.subarray(bufferLength - rowBytes, bufferLength);
|
||||||
|
if (prevRow.length === 0) {
|
||||||
|
prevRow = new Uint8Array(rowBytes);
|
||||||
|
}
|
||||||
|
|
||||||
|
var i,
|
||||||
|
j = bufferLength,
|
||||||
|
up,
|
||||||
|
c;
|
||||||
|
switch (predictor) {
|
||||||
|
case 0:
|
||||||
|
for (i = 0; i < rowBytes; ++i) {
|
||||||
|
buffer[j++] = rawBytes[i];
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 1:
|
||||||
|
for (i = 0; i < pixBytes; ++i) {
|
||||||
|
buffer[j++] = rawBytes[i];
|
||||||
|
}
|
||||||
|
for (; i < rowBytes; ++i) {
|
||||||
|
buffer[j] = (buffer[j - pixBytes] + rawBytes[i]) & 0xff;
|
||||||
|
j++;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 2:
|
||||||
|
for (i = 0; i < rowBytes; ++i) {
|
||||||
|
buffer[j++] = (prevRow[i] + rawBytes[i]) & 0xff;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 3:
|
||||||
|
for (i = 0; i < pixBytes; ++i) {
|
||||||
|
buffer[j++] = (prevRow[i] >> 1) + rawBytes[i];
|
||||||
|
}
|
||||||
|
for (; i < rowBytes; ++i) {
|
||||||
|
buffer[j] =
|
||||||
|
(((prevRow[i] + buffer[j - pixBytes]) >> 1) + rawBytes[i]) & 0xff;
|
||||||
|
j++;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 4:
|
||||||
|
// we need to save the up left pixels values. the simplest way
|
||||||
|
// is to create a new buffer
|
||||||
|
for (i = 0; i < pixBytes; ++i) {
|
||||||
|
up = prevRow[i];
|
||||||
|
c = rawBytes[i];
|
||||||
|
buffer[j++] = up + c;
|
||||||
|
}
|
||||||
|
for (; i < rowBytes; ++i) {
|
||||||
|
up = prevRow[i];
|
||||||
|
var upLeft = prevRow[i - pixBytes];
|
||||||
|
var left = buffer[j - pixBytes];
|
||||||
|
var p = left + up - upLeft;
|
||||||
|
|
||||||
|
var pa = p - left;
|
||||||
|
if (pa < 0) {
|
||||||
|
pa = -pa;
|
||||||
|
}
|
||||||
|
var pb = p - up;
|
||||||
|
if (pb < 0) {
|
||||||
|
pb = -pb;
|
||||||
|
}
|
||||||
|
var pc = p - upLeft;
|
||||||
|
if (pc < 0) {
|
||||||
|
pc = -pc;
|
||||||
|
}
|
||||||
|
|
||||||
|
c = rawBytes[i];
|
||||||
|
if (pa <= pb && pa <= pc) {
|
||||||
|
buffer[j++] = left + c;
|
||||||
|
} else if (pb <= pc) {
|
||||||
|
buffer[j++] = up + c;
|
||||||
|
} else {
|
||||||
|
buffer[j++] = upLeft + c;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
throw new FormatError(`Unsupported predictor: ${predictor}`);
|
||||||
|
}
|
||||||
|
this.bufferLength += rowBytes;
|
||||||
|
};
|
||||||
|
|
||||||
|
return PredictorStream;
|
||||||
|
})();
|
||||||
|
|
||||||
|
export { PredictorStream };
|
||||||
@ -21,7 +21,6 @@
|
|||||||
/* eslint-disable no-var */
|
/* eslint-disable no-var */
|
||||||
|
|
||||||
import { FormatError, stringToBytes, unreachable } from "../shared/util.js";
|
import { FormatError, stringToBytes, unreachable } from "../shared/util.js";
|
||||||
import { isDict } from "./primitives.js";
|
|
||||||
|
|
||||||
var Stream = (function StreamClosure() {
|
var Stream = (function StreamClosure() {
|
||||||
// eslint-disable-next-line no-shadow
|
// eslint-disable-next-line no-shadow
|
||||||
@ -726,228 +725,6 @@ var FlateStream = (function FlateStreamClosure() {
|
|||||||
return FlateStream;
|
return FlateStream;
|
||||||
})();
|
})();
|
||||||
|
|
||||||
var PredictorStream = (function PredictorStreamClosure() {
|
|
||||||
// eslint-disable-next-line no-shadow
|
|
||||||
function PredictorStream(str, maybeLength, params) {
|
|
||||||
if (!isDict(params)) {
|
|
||||||
return str; // no prediction
|
|
||||||
}
|
|
||||||
var predictor = (this.predictor = params.get("Predictor") || 1);
|
|
||||||
|
|
||||||
if (predictor <= 1) {
|
|
||||||
return str; // no prediction
|
|
||||||
}
|
|
||||||
if (predictor !== 2 && (predictor < 10 || predictor > 15)) {
|
|
||||||
throw new FormatError(`Unsupported predictor: ${predictor}`);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (predictor === 2) {
|
|
||||||
this.readBlock = this.readBlockTiff;
|
|
||||||
} else {
|
|
||||||
this.readBlock = this.readBlockPng;
|
|
||||||
}
|
|
||||||
|
|
||||||
this.str = str;
|
|
||||||
this.dict = str.dict;
|
|
||||||
|
|
||||||
var colors = (this.colors = params.get("Colors") || 1);
|
|
||||||
var bits = (this.bits = params.get("BitsPerComponent") || 8);
|
|
||||||
var columns = (this.columns = params.get("Columns") || 1);
|
|
||||||
|
|
||||||
this.pixBytes = (colors * bits + 7) >> 3;
|
|
||||||
this.rowBytes = (columns * colors * bits + 7) >> 3;
|
|
||||||
|
|
||||||
DecodeStream.call(this, maybeLength);
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
PredictorStream.prototype = Object.create(DecodeStream.prototype);
|
|
||||||
|
|
||||||
PredictorStream.prototype.readBlockTiff = function predictorStreamReadBlockTiff() {
|
|
||||||
var rowBytes = this.rowBytes;
|
|
||||||
|
|
||||||
var bufferLength = this.bufferLength;
|
|
||||||
var buffer = this.ensureBuffer(bufferLength + rowBytes);
|
|
||||||
|
|
||||||
var bits = this.bits;
|
|
||||||
var colors = this.colors;
|
|
||||||
|
|
||||||
var rawBytes = this.str.getBytes(rowBytes);
|
|
||||||
this.eof = !rawBytes.length;
|
|
||||||
if (this.eof) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
var inbuf = 0,
|
|
||||||
outbuf = 0;
|
|
||||||
var inbits = 0,
|
|
||||||
outbits = 0;
|
|
||||||
var pos = bufferLength;
|
|
||||||
var i;
|
|
||||||
|
|
||||||
if (bits === 1 && colors === 1) {
|
|
||||||
// Optimized version of the loop in the "else"-branch
|
|
||||||
// for 1 bit-per-component and 1 color TIFF images.
|
|
||||||
for (i = 0; i < rowBytes; ++i) {
|
|
||||||
var c = rawBytes[i] ^ inbuf;
|
|
||||||
c ^= c >> 1;
|
|
||||||
c ^= c >> 2;
|
|
||||||
c ^= c >> 4;
|
|
||||||
inbuf = (c & 1) << 7;
|
|
||||||
buffer[pos++] = c;
|
|
||||||
}
|
|
||||||
} else if (bits === 8) {
|
|
||||||
for (i = 0; i < colors; ++i) {
|
|
||||||
buffer[pos++] = rawBytes[i];
|
|
||||||
}
|
|
||||||
for (; i < rowBytes; ++i) {
|
|
||||||
buffer[pos] = buffer[pos - colors] + rawBytes[i];
|
|
||||||
pos++;
|
|
||||||
}
|
|
||||||
} else if (bits === 16) {
|
|
||||||
var bytesPerPixel = colors * 2;
|
|
||||||
for (i = 0; i < bytesPerPixel; ++i) {
|
|
||||||
buffer[pos++] = rawBytes[i];
|
|
||||||
}
|
|
||||||
for (; i < rowBytes; i += 2) {
|
|
||||||
var sum =
|
|
||||||
((rawBytes[i] & 0xff) << 8) +
|
|
||||||
(rawBytes[i + 1] & 0xff) +
|
|
||||||
((buffer[pos - bytesPerPixel] & 0xff) << 8) +
|
|
||||||
(buffer[pos - bytesPerPixel + 1] & 0xff);
|
|
||||||
buffer[pos++] = (sum >> 8) & 0xff;
|
|
||||||
buffer[pos++] = sum & 0xff;
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
var compArray = new Uint8Array(colors + 1);
|
|
||||||
var bitMask = (1 << bits) - 1;
|
|
||||||
var j = 0,
|
|
||||||
k = bufferLength;
|
|
||||||
var columns = this.columns;
|
|
||||||
for (i = 0; i < columns; ++i) {
|
|
||||||
for (var kk = 0; kk < colors; ++kk) {
|
|
||||||
if (inbits < bits) {
|
|
||||||
inbuf = (inbuf << 8) | (rawBytes[j++] & 0xff);
|
|
||||||
inbits += 8;
|
|
||||||
}
|
|
||||||
compArray[kk] =
|
|
||||||
(compArray[kk] + (inbuf >> (inbits - bits))) & bitMask;
|
|
||||||
inbits -= bits;
|
|
||||||
outbuf = (outbuf << bits) | compArray[kk];
|
|
||||||
outbits += bits;
|
|
||||||
if (outbits >= 8) {
|
|
||||||
buffer[k++] = (outbuf >> (outbits - 8)) & 0xff;
|
|
||||||
outbits -= 8;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (outbits > 0) {
|
|
||||||
buffer[k++] =
|
|
||||||
(outbuf << (8 - outbits)) + (inbuf & ((1 << (8 - outbits)) - 1));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
this.bufferLength += rowBytes;
|
|
||||||
};
|
|
||||||
|
|
||||||
PredictorStream.prototype.readBlockPng = function predictorStreamReadBlockPng() {
|
|
||||||
var rowBytes = this.rowBytes;
|
|
||||||
var pixBytes = this.pixBytes;
|
|
||||||
|
|
||||||
var predictor = this.str.getByte();
|
|
||||||
var rawBytes = this.str.getBytes(rowBytes);
|
|
||||||
this.eof = !rawBytes.length;
|
|
||||||
if (this.eof) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
var bufferLength = this.bufferLength;
|
|
||||||
var buffer = this.ensureBuffer(bufferLength + rowBytes);
|
|
||||||
|
|
||||||
var prevRow = buffer.subarray(bufferLength - rowBytes, bufferLength);
|
|
||||||
if (prevRow.length === 0) {
|
|
||||||
prevRow = new Uint8Array(rowBytes);
|
|
||||||
}
|
|
||||||
|
|
||||||
var i,
|
|
||||||
j = bufferLength,
|
|
||||||
up,
|
|
||||||
c;
|
|
||||||
switch (predictor) {
|
|
||||||
case 0:
|
|
||||||
for (i = 0; i < rowBytes; ++i) {
|
|
||||||
buffer[j++] = rawBytes[i];
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case 1:
|
|
||||||
for (i = 0; i < pixBytes; ++i) {
|
|
||||||
buffer[j++] = rawBytes[i];
|
|
||||||
}
|
|
||||||
for (; i < rowBytes; ++i) {
|
|
||||||
buffer[j] = (buffer[j - pixBytes] + rawBytes[i]) & 0xff;
|
|
||||||
j++;
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case 2:
|
|
||||||
for (i = 0; i < rowBytes; ++i) {
|
|
||||||
buffer[j++] = (prevRow[i] + rawBytes[i]) & 0xff;
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case 3:
|
|
||||||
for (i = 0; i < pixBytes; ++i) {
|
|
||||||
buffer[j++] = (prevRow[i] >> 1) + rawBytes[i];
|
|
||||||
}
|
|
||||||
for (; i < rowBytes; ++i) {
|
|
||||||
buffer[j] =
|
|
||||||
(((prevRow[i] + buffer[j - pixBytes]) >> 1) + rawBytes[i]) & 0xff;
|
|
||||||
j++;
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case 4:
|
|
||||||
// we need to save the up left pixels values. the simplest way
|
|
||||||
// is to create a new buffer
|
|
||||||
for (i = 0; i < pixBytes; ++i) {
|
|
||||||
up = prevRow[i];
|
|
||||||
c = rawBytes[i];
|
|
||||||
buffer[j++] = up + c;
|
|
||||||
}
|
|
||||||
for (; i < rowBytes; ++i) {
|
|
||||||
up = prevRow[i];
|
|
||||||
var upLeft = prevRow[i - pixBytes];
|
|
||||||
var left = buffer[j - pixBytes];
|
|
||||||
var p = left + up - upLeft;
|
|
||||||
|
|
||||||
var pa = p - left;
|
|
||||||
if (pa < 0) {
|
|
||||||
pa = -pa;
|
|
||||||
}
|
|
||||||
var pb = p - up;
|
|
||||||
if (pb < 0) {
|
|
||||||
pb = -pb;
|
|
||||||
}
|
|
||||||
var pc = p - upLeft;
|
|
||||||
if (pc < 0) {
|
|
||||||
pc = -pc;
|
|
||||||
}
|
|
||||||
|
|
||||||
c = rawBytes[i];
|
|
||||||
if (pa <= pb && pa <= pc) {
|
|
||||||
buffer[j++] = left + c;
|
|
||||||
} else if (pb <= pc) {
|
|
||||||
buffer[j++] = up + c;
|
|
||||||
} else {
|
|
||||||
buffer[j++] = upLeft + c;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
throw new FormatError(`Unsupported predictor: ${predictor}`);
|
|
||||||
}
|
|
||||||
this.bufferLength += rowBytes;
|
|
||||||
};
|
|
||||||
|
|
||||||
return PredictorStream;
|
|
||||||
})();
|
|
||||||
|
|
||||||
var NullStream = (function NullStreamClosure() {
|
var NullStream = (function NullStreamClosure() {
|
||||||
// eslint-disable-next-line no-shadow
|
// eslint-disable-next-line no-shadow
|
||||||
function NullStream() {
|
function NullStream() {
|
||||||
@ -963,7 +740,6 @@ export {
|
|||||||
DecodeStream,
|
DecodeStream,
|
||||||
FlateStream,
|
FlateStream,
|
||||||
NullStream,
|
NullStream,
|
||||||
PredictorStream,
|
|
||||||
Stream,
|
Stream,
|
||||||
StreamsSequenceStream,
|
StreamsSequenceStream,
|
||||||
StringStream,
|
StringStream,
|
||||||
|
|||||||
@ -13,8 +13,9 @@
|
|||||||
* limitations under the License.
|
* limitations under the License.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
import { PredictorStream, Stream } from "../../src/core/stream.js";
|
|
||||||
import { Dict } from "../../src/core/primitives.js";
|
import { Dict } from "../../src/core/primitives.js";
|
||||||
|
import { PredictorStream } from "../../src/core/predictor_stream.js";
|
||||||
|
import { Stream } from "../../src/core/stream.js";
|
||||||
|
|
||||||
describe("stream", function () {
|
describe("stream", function () {
|
||||||
beforeEach(function () {
|
beforeEach(function () {
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user