Index: sdk/lib/_internal/pub/lib/src/utils.dart |
diff --git a/sdk/lib/_internal/pub/lib/src/utils.dart b/sdk/lib/_internal/pub/lib/src/utils.dart |
index da8f640e85dbed58d61939d658fcb017c0310d53..372f7def98b8a7a98928bf1d3e0fc52bfd7787a0 100644 |
--- a/sdk/lib/_internal/pub/lib/src/utils.dart |
+++ b/sdk/lib/_internal/pub/lib/src/utils.dart |
@@ -191,7 +191,10 @@ Future<Stream> validateStream(Stream stream) { |
controller.add(value); |
}, onError: (error) { |
// If the error came after values, it's OK. |
- if (completer.isCompleted) controller.addError(error); |
+ if (completer.isCompleted) { |
+ controller.addError(error); |
+ return; |
+ } |
// Otherwise, the error came first and the stream is invalid. |
completer.completeError(error); |