| Index: test/generated_sdk/lib/async/stream.dart
|
| diff --git a/test/generated_sdk/lib/async/stream.dart b/test/generated_sdk/lib/async/stream.dart
|
| index 3e5d09e1227965c3ba61b535e1f4638932a7f256..6d1fc63b37c43c283544a2f01c83d2b8c8810c18 100644
|
| --- a/test/generated_sdk/lib/async/stream.dart
|
| +++ b/test/generated_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),
|
|
|