diff --git a/index.js b/index.js
index <HASH>..<HASH> 100644
--- a/index.js
+++ b/index.js
@@ -21,6 +21,7 @@ module.exports = function (_cb) {
     handshake: {
       read: reader.read,
       abort: function (err) {
+        writer.end(err)
         reader.abort(err, function (err) {
         })
         _cb(err)
abort source and sink on an error