diff --git a/ts/00_commitinfo_data.ts b/ts/00_commitinfo_data.ts index 5991568..86ce865 100644 --- a/ts/00_commitinfo_data.ts +++ b/ts/00_commitinfo_data.ts @@ -3,6 +3,6 @@ */ export const commitinfo = { name: '@push.rocks/smartarchive', - version: '4.0.21', + version: '4.0.22', description: 'work with archives' } diff --git a/ts/classes.smartarchive.ts b/ts/classes.smartarchive.ts index f4bba4b..d68b380 100644 --- a/ts/classes.smartarchive.ts +++ b/ts/classes.smartarchive.ts @@ -141,6 +141,9 @@ export class SmartArchive { writeFunction: async (streamFileArg: plugins.smartfile.StreamFile, streamtools) => { streamFileIntake.push(streamFileArg); }, + finalFunction: async () => { + streamFileIntake.signalEnd(); + } })); } else if (analyzedResultChunk.isArchive && analyzedResultChunk.decompressionStream) { analyzedResultChunk.resultStream diff --git a/ts/classes.ziptools.ts b/ts/classes.ziptools.ts index 43177cf..5f2a21f 100644 --- a/ts/classes.ziptools.ts +++ b/ts/classes.ziptools.ts @@ -26,7 +26,7 @@ class DecompressZipTransform extends plugins.smartstream.SmartDuplex { this.unzipper.push(Buffer.from(''), true); await plugins.smartdelay.delayFor(0); - this.streamtools.push(null); + await this.streamtools.push(null); } }); this.unzipper.register(plugins.fflate.UnzipInflate);