Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(232)

Unified Diff: tool/input_sdk/lib/async/stream.dart

Issue 1112403004: SDK fixes (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Formatting fix Created 5 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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 3e5d09e1227965c3ba61b535e1f4638932a7f256..6d1fc63b37c43c283544a2f01c83d2b8c8810c18 100644
--- a/tool/input_sdk/lib/async/stream.dart
+++ b/tool/input_sdk/lib/async/stream.dart
@@ -84,7 +84,8 @@ abstract class Stream<T> {
// Use the controller's buffering to fill in the value even before
// the stream has a listener. For a single value, it's not worth it
// to wait for a listener before doing the `then` on the future.
- _StreamController<T> controller = new StreamController<T>(sync: true);
+ _StreamController<T> controller =
+ new StreamController<T>(sync: true) as _StreamController<T>;
future.then((value) {
controller._add(value);
controller._closeUnchecked();
@@ -1409,8 +1410,8 @@ class StreamView<T> extends Stream<T> {
bool get isBroadcast => _stream.isBroadcast;
- Stream<T> asBroadcastStream({void onListen(StreamSubscription subscription),
- void onCancel(StreamSubscription subscription)})
+ Stream<T> asBroadcastStream({void onListen(StreamSubscription<T> subscription),
+ void onCancel(StreamSubscription<T> subscription)})
=> _stream.asBroadcastStream(onListen: onListen, onCancel: onCancel);
StreamSubscription<T> listen(void onData(T value),

Powered by Google App Engine
This is Rietveld 408576698