Index: sdk/lib/io/http_parser.dart |
diff --git a/sdk/lib/io/http_parser.dart b/sdk/lib/io/http_parser.dart |
index c2b08e40895f472ff4be793108628dace19666a3..5eb96ce350bf05f0d93f61857154f223aca33bde 100644 |
--- a/sdk/lib/io/http_parser.dart |
+++ b/sdk/lib/io/http_parser.dart |
@@ -183,7 +183,7 @@ class _HttpDetachedStreamSubscription implements StreamSubscription<List<int>> { |
class _HttpDetachedIncoming extends Stream<List<int>> { |
- final StreamSubscription<List<int>> subscription; |
+ final StreamSubscription subscription; |
final List<int> bufferedData; |
_HttpDetachedIncoming(this.subscription, this.bufferedData); |
@@ -205,8 +205,7 @@ class _HttpDetachedIncoming extends Stream<List<int>> { |
onData) |
..resume(); |
} else { |
- // TODO(26379): add test for this branch. |
- return new Stream<List<int>>.fromIterable([bufferedData]) |
+ return new Stream.fromIterable(bufferedData) |
.listen(onData, |
onError: onError, |
onDone: onDone, |
@@ -268,7 +267,7 @@ class _HttpParser extends Stream<_HttpIncoming> { |
// The current incoming connection. |
_HttpIncoming _incoming; |
- StreamSubscription<List<int>> _socketSubscription; |
+ StreamSubscription _socketSubscription; |
bool _paused = true; |
bool _bodyPaused = false; |
StreamController<_HttpIncoming> _controller; |