Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
5d94efb9ee | |||
c978ca107b |
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@push.rocks/smartarchive",
|
"name": "@push.rocks/smartarchive",
|
||||||
"version": "4.0.21",
|
"version": "4.0.22",
|
||||||
"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.21',
|
version: '4.0.22',
|
||||||
description: 'work with archives'
|
description: 'work with archives'
|
||||||
}
|
}
|
||||||
|
@ -141,6 +141,9 @@ export class SmartArchive {
|
|||||||
writeFunction: async (streamFileArg: plugins.smartfile.StreamFile, streamtools) => {
|
writeFunction: async (streamFileArg: plugins.smartfile.StreamFile, streamtools) => {
|
||||||
streamFileIntake.push(streamFileArg);
|
streamFileIntake.push(streamFileArg);
|
||||||
},
|
},
|
||||||
|
finalFunction: async () => {
|
||||||
|
streamFileIntake.signalEnd();
|
||||||
|
}
|
||||||
}));
|
}));
|
||||||
} else if (analyzedResultChunk.isArchive && analyzedResultChunk.decompressionStream) {
|
} else if (analyzedResultChunk.isArchive && analyzedResultChunk.decompressionStream) {
|
||||||
analyzedResultChunk.resultStream
|
analyzedResultChunk.resultStream
|
||||||
|
@ -26,7 +26,7 @@ class DecompressZipTransform extends plugins.smartstream.SmartDuplex<ArrayBuffer
|
|||||||
finalFunction: async () => {
|
finalFunction: async () => {
|
||||||
this.unzipper.push(Buffer.from(''), true);
|
this.unzipper.push(Buffer.from(''), true);
|
||||||
await plugins.smartdelay.delayFor(0);
|
await plugins.smartdelay.delayFor(0);
|
||||||
this.streamtools.push(null);
|
await this.streamtools.push(null);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
this.unzipper.register(plugins.fflate.UnzipInflate);
|
this.unzipper.register(plugins.fflate.UnzipInflate);
|
||||||
|
Reference in New Issue
Block a user