diff --git a/lib/file-stream.js b/lib/file-stream.js index 508f3584f2..11514b4875 100644 --- a/lib/file-stream.js +++ b/lib/file-stream.js @@ -56,6 +56,8 @@ FileStream.prototype._notify = function () { if (self._notifying) return self._notifying = true + if (self._torrent.destroyed) return self._destroy(new Error('Torrent removed')) + var p = self._piece self._torrent.store.get(p, function (err, buffer) { self._notifying = false