fix(core): update

This commit is contained in:
Philipp Kunz 2021-04-19 12:15:23 +00:00
parent 02a0646a49
commit 70a08fd92b
2 changed files with 22 additions and 10 deletions

View File

@ -60,23 +60,35 @@ tap.test('should extract a package using tarStream', async (tools) => {
const extractionFileObservable = await testSmartarchive.extractArchiveFromBufferToObservable( const extractionFileObservable = await testSmartarchive.extractArchiveFromBufferToObservable(
testTgzBuffer testTgzBuffer
); );
const subscription = extractionFileObservable.subscribe(file => { const subscription = extractionFileObservable.subscribe(
console.log(file.path); (file) => {
}); console.log(file.path);
await tools.delayFor(2000); },
done.resolve(); (err) => {
console.log(err);
},
() => {
done.resolve();
}
);
await done.promise; await done.promise;
}); });
tap.test('should extract a file from url to replaySubject', async (tools) => { tap.test('should extract a file from url to replaySubject', async (tools) => {
const done = tools.defer(); const done = tools.defer();
const testSmartarchive = new smartarchive.SmartArchive(); const testSmartarchive = new smartarchive.SmartArchive();
const extractionFileObservable = await testSmartarchive.extractArchiveFromUrlToObservable('https://verdaccio.lossless.one/@pushrocks%2fwebsetup/-/websetup-2.0.14.tgz'); const extractionFileObservable = await testSmartarchive.extractArchiveFromUrlToObservable(
const subscription = extractionFileObservable.subscribe(file => { 'https://verdaccio.lossless.one/@pushrocks%2fwebsetup/-/websetup-2.0.14.tgz'
);
const subscription = extractionFileObservable.subscribe((file) => {
console.log(file.path); console.log(file.path);
},
(err) => {
console.log(err);
},
() => {
done.resolve();
}); });
await tools.delayFor(2000);
done.resolve();
await done.promise; await done.promise;
}); });

View File

@ -68,7 +68,7 @@ export class SmartArchive {
stream.resume(); stream.resume();
}); });
extractPipeStop.on('finish', () => { extractPipeStop.on('finish', () => {
replaySubject.unsubscribe(); replaySubject.complete();
}); });
// lets run the stream // lets run the stream
readableStream readableStream