Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
ad0352a712 | |||
f921338fd6 |
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@push.rocks/smartarchive",
|
"name": "@push.rocks/smartarchive",
|
||||||
"version": "4.0.15",
|
"version": "4.0.16",
|
||||||
"description": "work with archives",
|
"description": "work with archives",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
"typings": "dist_ts/index.d.ts",
|
"typings": "dist_ts/index.d.ts",
|
||||||
|
@ -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;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user