Index: sdk/lib/async/stream_transformers.dart |
diff --git a/sdk/lib/async/stream_transformers.dart b/sdk/lib/async/stream_transformers.dart |
index 27f1547fc4e30ec2da46806f0b3f41ff8f8fac0e..640d31c8e390aa8aedd9633c1f2a5aacdc21fcb6 100644 |
--- a/sdk/lib/async/stream_transformers.dart |
+++ b/sdk/lib/async/stream_transformers.dart |
@@ -220,17 +220,9 @@ class _HandlerEventSink<S, T> implements EventSink<S> { |
bool get _isClosed => _sink == null; |
- _reportClosedSink() { |
- // TODO(29554): throw a StateError, and don't just report the problem. |
- Zone.ROOT |
- ..print("Sink is closed and adding to it is an error.") |
- ..print(" See http://dartbug.com/29554.") |
- ..print(StackTrace.current.toString()); |
- } |
- |
void add(S data) { |
if (_isClosed) { |
- _reportClosedSink(); |
+ throw new StateError("Sink is closed"); |
} |
if (_handleData != null) { |
_handleData(data, _sink); |
@@ -241,7 +233,7 @@ class _HandlerEventSink<S, T> implements EventSink<S> { |
void addError(Object error, [StackTrace stackTrace]) { |
if (_isClosed) { |
- _reportClosedSink(); |
+ throw new StateError("Sink is closed"); |
} |
if (_handleError != null) { |
_handleError(error, stackTrace, _sink); |