fix(core): update
This commit is contained in:
		| @@ -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