Skip to content

Commit 90cb0d8

Browse files
committed
fix: fix properly listening for end of request
fixes #55 this was happening due to a new change with miniget v2.1.0
1 parent 34057ed commit 90cb0d8

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

lib/feedsub.js

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -290,15 +290,18 @@ module.exports = class FeedReader extends EventEmitter {
290290

291291
req.pipe(parser);
292292

293-
req.on('end', () => {
293+
const onEnd = () => {
294294
if (ended) { return; }
295295
// Process items in descending order if no order found at end.
296296
if (sortOrder === 0 && newItems.length === 0) {
297297
items.forEach(getOlderItem);
298298
}
299299
success();
300300
this.first = false;
301-
});
301+
};
302+
303+
req.on('close', onEnd);
304+
req.on('end', onEnd);
302305
});
303306

304307
req.on('error', error.bind(null, false));

0 commit comments

Comments
 (0)