diff --git a/reference-extension-stop.js b/reference-extension-stop.js index 62ba5c5..b6aae41 100644 --- a/reference-extension-stop.js +++ b/reference-extension-stop.js @@ -19,6 +19,7 @@ class StopExtensionSource extends Source { pull (error, buffer) { if (this[kStopped]) { this.sink.next(status_type.end, null, buffer, 0) + return } // ... else ...