From 487023b2c0b1592b559e5ca6f7b939f19a4a56fb Mon Sep 17 00:00:00 2001
From: Sven Slootweg <admin@cryto.net>
Date: Tue, 23 Apr 2019 23:13:49 +0200
Subject: [PATCH] Move abort propagation logic to separate module

---
 index.js     | 5 ++---
 package.json | 1 +
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/index.js b/index.js
index 2131eca..57a453d 100644
--- a/index.js
+++ b/index.js
@@ -3,6 +3,7 @@
 const Promise = require("bluebird");
 const ms = require("ms");
 const promiseDelaySince = require("@joepie91/promise-delay-every");
+const propagateAbort = require("@ppstreams/propagate-abort");
 
 module.exports = function rateLimitedStream(interval) {
 	let intervalInMilliseconds = (typeof interval === "number")
@@ -20,8 +21,6 @@ module.exports = function rateLimitedStream(interval) {
 				return source.read();
 			});
 		},
-		abort: (source, reason) => {
-			source.abort(reason);
-		}
+		abort: propagateAbort
 	}
 };
\ No newline at end of file
diff --git a/package.json b/package.json
index 9b75532..7b38273 100644
--- a/package.json
+++ b/package.json
@@ -7,6 +7,7 @@
   "license": "WTFPL OR CC0-1.0",
   "dependencies": {
     "@joepie91/promise-delay-every": "^1.0.0",
+    "@ppstreams/propagate-abort": "^0.1.2",
     "bluebird": "^3.5.4",
     "ms": "^2.1.1"
   }