diff --git a/src/fetchers/tarball-fetcher.js b/src/fetchers/tarball-fetcher.js
index 6ff6ccb10c..916f739410 100644
--- a/src/fetchers/tarball-fetcher.js
+++ b/src/fetchers/tarball-fetcher.js
@@ -231,9 +231,9 @@ export default class TarballFetcher extends BaseFetcher {
       );
 
       stream.pipe(hashValidateStream);
-      stream.pipe(integrityValidateStream);
+      hashValidateStream.pipe(integrityValidateStream);
 
-      stream.pipe(extractorStream).on('error', err => {
+      integrityValidateStream.pipe(extractorStream).on('error', err => {
         reject(new MessageError(this.config.reporter.lang('fetchErrorCorrupt', err.message, tarballPath)));
       });
     });