fix(core): update
This commit is contained in:
parent
614dae5ade
commit
f921338fd6
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@push.rocks/smartarchive',
|
name: '@push.rocks/smartarchive',
|
||||||
version: '4.0.15',
|
version: '4.0.16',
|
||||||
description: 'work with archives'
|
description: 'work with archives'
|
||||||
}
|
}
|
||||||
|
@ -54,12 +54,11 @@ export function unbzip2Stream() {
|
|||||||
let counter = 0;
|
let counter = 0;
|
||||||
return new plugins.smartstream.SmartDuplex({
|
return new plugins.smartstream.SmartDuplex({
|
||||||
objectMode: true,
|
objectMode: true,
|
||||||
// writableObjectMode: true,
|
|
||||||
name: 'bzip2',
|
name: 'bzip2',
|
||||||
debug: true,
|
// debug: true,
|
||||||
highWaterMark: 1,
|
highWaterMark: 1,
|
||||||
writeFunction: async function (data, streamTools) {
|
writeFunction: async function (data, streamTools) {
|
||||||
console.log(`got chunk ${counter++}`)
|
// console.log(`got chunk ${counter++}`)
|
||||||
bufferQueue.push(data);
|
bufferQueue.push(data);
|
||||||
hasBytes += data.length;
|
hasBytes += data.length;
|
||||||
if (bitReader === null) {
|
if (bitReader === null) {
|
||||||
|
@ -4,7 +4,7 @@ import * as plugins from './plugins.js';
|
|||||||
export interface IAnalyzedResult {
|
export interface IAnalyzedResult {
|
||||||
fileType: plugins.fileType.FileTypeResult;
|
fileType: plugins.fileType.FileTypeResult;
|
||||||
isArchive: boolean;
|
isArchive: boolean;
|
||||||
resultStream: plugins.smartstream.PassThrough;
|
resultStream: plugins.smartstream.SmartDuplex;
|
||||||
decompressionStream: plugins.stream.Transform | plugins.stream.Duplex | plugins.tarStream.Extract;
|
decompressionStream: plugins.stream.Transform | plugins.stream.Duplex | plugins.tarStream.Extract;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user