Index: sdk/lib/async/stream_controller.dart |
diff --git a/sdk/lib/async/stream_controller.dart b/sdk/lib/async/stream_controller.dart |
index a9f5e71d7db2803bbbf2d846727a7a55825c2583..240d5661717276f0098d6b3f77b25f2a9b853b6c 100644 |
--- a/sdk/lib/async/stream_controller.dart |
+++ b/sdk/lib/async/stream_controller.dart |
@@ -46,7 +46,7 @@ part of dart.async; |
* the stream at all, and won't trigger callbacks. From the controller's point |
* of view, the stream is completely inert when has completed. |
*/ |
-class StreamController<T> implements StreamSink<T> { |
+class StreamController<T> implements EventSink<T> { |
final _StreamImpl<T> stream; |
/** |
@@ -85,9 +85,9 @@ class StreamController<T> implements StreamSink<T> { |
onPauseStateChange); |
/** |
- * Returns a view of this object that only exposes the [StreamSink] interface. |
+ * Returns a view of this object that only exposes the [EventSink] interface. |
*/ |
- StreamSink<T> get sink => new StreamSinkView<T>(this); |
+ EventSink<T> get sink => new EventSinkView<T>(this); |
/** |
* Whether the stream is closed for adding more events. |
@@ -120,14 +120,18 @@ class StreamController<T> implements StreamSink<T> { |
* If a subscription has requested to be unsubscribed on errors, |
* it will be unsubscribed after receiving this event. |
*/ |
- void signalError(Object error, [Object stackTrace]) { |
+ void addError(Object error, [Object stackTrace]) { |
AsyncError asyncError; |
if (error is AsyncError) { |
asyncError = error; |
} else { |
asyncError = new AsyncError(error, stackTrace); |
} |
- stream._signalError(asyncError); |
+ stream._addError(asyncError); |
+ } |
+ |
+ void signalError(Object error, [Object stackTrace]) { |
+ addError(error, stackTrace); |
} |
/** |