| 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..5097da605f7aa48eb3dbab6a365484ccc17e83ba 100644
|
| --- a/sdk/lib/async/stream_controller.dart
|
| +++ b/sdk/lib/async/stream_controller.dart
|
| @@ -46,7 +46,8 @@ 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> extends StreamSink<T> {
|
| + // TODO(8997): Implement EventSink instead.
|
| final _StreamImpl<T> stream;
|
|
|
| /**
|
| @@ -85,9 +86,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 +121,14 @@ 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);
|
| }
|
|
|
| /**
|
|
|