Index: lib/src/stream_group.dart |
diff --git a/lib/src/stream_group.dart b/lib/src/stream_group.dart |
index 889ccd82685af96a2e5933b9228231804bd50bc6..4aa448e303e9513a8f99e98c87ef56451ea3e483 100644 |
--- a/lib/src/stream_group.dart |
+++ b/lib/src/stream_group.dart |
@@ -53,8 +53,8 @@ class StreamGroup<T> implements Sink<Stream<T>> { |
/// |
/// This is equivalent to adding [streams] to a group, closing that group, and |
/// returning its stream. |
- static Stream/*<T>*/ merge/*<T>*/(Iterable<Stream/*<T>*/> streams) { |
- var group = new StreamGroup/*<T>*/(); |
+ static Stream<T> merge<T>(Iterable<Stream<T>> streams) { |
+ var group = new StreamGroup<T>(); |
streams.forEach(group.add); |
group.close(); |
return group.stream; |