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 f81667776f0e099634de363d85370fce6c799da2..c4c2c07fa89db5e559ac7ee9da8e67f023289e08 100644 |
--- a/tool/input_sdk/lib/async/stream.dart |
+++ b/tool/input_sdk/lib/async/stream.dart |
@@ -296,8 +296,8 @@ abstract class Stream<T> { |
* If a broadcast stream is listened to more than once, each subscription |
* will individually execute `map` for each event. |
*/ |
- Stream map(convert(T event)) { |
- return new _MapStream<T, dynamic>(this, convert); |
+ Stream/*<S>*/ map/*<S>*/(/*=S*/ convert(T event)) { |
+ return new _MapStream<T, dynamic/*=S*/>(this, convert); |
} |
/** |
@@ -458,8 +458,8 @@ abstract class Stream<T> { |
* If a broadcast stream is listened to more than once, each subscription |
* will individually call `convert` and expand the events. |
*/ |
- Stream expand(Iterable convert(T value)) { |
- return new _ExpandStream<T, dynamic>(this, convert); |
+ Stream/*<S>*/ expand/*<S>*/(Iterable/*<S>*/ convert(T value)) { |
+ return new _ExpandStream<T, dynamic/*=S*/>(this, convert); |
} |
/** |
@@ -523,8 +523,9 @@ abstract class Stream<T> { |
} |
/** Reduces a sequence of values by repeatedly applying [combine]. */ |
- Future fold(var initialValue, combine(var previous, T element)) { |
- _Future result = new _Future(); |
+ Future/*<S>*/ fold/*<S>*/(var/*=S*/ initialValue, |
+ /*=S*/ combine(var/*=S*/ previous, T element)) { |
+ _Future/*<S>*/ result = new _Future(); |
var value = initialValue; |
StreamSubscription subscription; |
subscription = this.listen( |
@@ -1568,7 +1569,7 @@ abstract class StreamTransformer<S, T> { |
*/ |
const factory StreamTransformer( |
StreamSubscription<T> transformer(Stream<S> stream, bool cancelOnError)) |
- = _StreamSubscriptionTransformer; |
+ = _StreamSubscriptionTransformer<S, T>; |
/** |
* Creates a [StreamTransformer] that delegates events to the given functions. |
@@ -1585,7 +1586,7 @@ abstract class StreamTransformer<S, T> { |
void handleData(S data, EventSink<T> sink), |
void handleError(Object error, StackTrace stackTrace, EventSink<T> sink), |
void handleDone(EventSink<T> sink)}) |
- = _StreamHandlerTransformer; |
+ = _StreamHandlerTransformer<S, T>; |
/** |
* Transform the incoming [stream]'s events. |