Index: lib/src/stream_splitter.dart |
diff --git a/lib/src/stream_splitter.dart b/lib/src/stream_splitter.dart |
index 448fe2a26ea926e2d3b75b3c5685bdb92b62bb80..3d8f994ee827a8e9784782c85f327035ee2989ef 100644 |
--- a/lib/src/stream_splitter.dart |
+++ b/lib/src/stream_splitter.dart |
@@ -57,10 +57,10 @@ class StreamSplitter<T> { |
/// |
/// [count] defaults to 2. This is the same as creating [count] branches and |
/// then closing the [StreamSplitter]. |
- static List<Stream/*<T>*/> splitFrom/*<T>*/(Stream/*<T>*/ stream, |
+ static List<Stream<T>> splitFrom<T>(Stream<T> stream, |
[int count]) { |
if (count == null) count = 2; |
- var splitter = new StreamSplitter/*<T>*/(stream); |
+ var splitter = new StreamSplitter<T>(stream); |
var streams = new List<Stream>.generate(count, (_) => splitter.split()); |
splitter.close(); |
return streams; |