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); |
} |