| Index: tool/input_sdk/lib/async/stream.dart
|
| diff --git a/tool/input_sdk/lib/async/stream.dart b/tool/input_sdk/lib/async/stream.dart
|
| index 6d1fc63b37c43c283544a2f01c83d2b8c8810c18..9497e07d30860fe4c310ed4c055ef8da7b5a5c0a 100644
|
| --- a/tool/input_sdk/lib/async/stream.dart
|
| +++ b/tool/input_sdk/lib/async/stream.dart
|
| @@ -317,7 +317,7 @@ abstract class Stream<T> {
|
| final add = controller.add;
|
| assert(controller is _StreamController ||
|
| controller is _BroadcastStreamController);
|
| - final eventSink = controller;
|
| + final eventSink = controller as _EventSink<T>;
|
| final addError = eventSink._addError;
|
| subscription = this.listen(
|
| (T event) {
|
| @@ -377,7 +377,7 @@ abstract class Stream<T> {
|
| void onListen() {
|
| assert(controller is _StreamController ||
|
| controller is _BroadcastStreamController);
|
| - final eventSink = controller;
|
| + final eventSink = controller as _EventSink<T>;
|
| subscription = this.listen(
|
| (T event) {
|
| Stream newStream;
|
| @@ -1223,7 +1223,7 @@ abstract class Stream<T> {
|
| timer.cancel();
|
| assert(controller is _StreamController ||
|
| controller is _BroadcastStreamController);
|
| - var eventSink = controller;
|
| + var eventSink = controller as _EventSink<T>;
|
| eventSink._addError(error, stackTrace); // Avoid Zone error replacement.
|
| timer = zone.createTimer(timeLimit, timeout);
|
| }
|
|
|