Revert "Fix remaining strong-mode warnings and errors in dart:io."

sdk/lib/io/http_parser.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 part of dart.io;
 
 // Global constants.
 class _Const {
   // Bytes for "HTTP".
   static const HTTP = const [72, 84, 84, 80];
@@ skipping 165 matching lines @@
       _subscription.resume();
       if (_userOnData != null) {
         _userOnData(data);
       }
     });
   }
 }
 
 
 class _HttpDetachedIncoming extends Stream<List<int>> {
-  final StreamSubscription<List<int>> subscription;
+  final StreamSubscription subscription;
   final List<int> bufferedData;
 
   _HttpDetachedIncoming(this.subscription, this.bufferedData);
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
                                        {Function onError,
                                         void onDone(),
                                         bool cancelOnError}) {
     if (subscription != null) {
       subscription
         ..onData(onData)
         ..onError(onError)
         ..onDone(onDone);
       if (bufferedData == null) {
         return subscription..resume();
       }
       return new _HttpDetachedStreamSubscription(subscription,
                                                  bufferedData,
                                                  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,
                   cancelOnError: cancelOnError);
     }
   }
 }
 
 
 /**
@@ skipping 41 matching lines @@
   bool _connectionUpgrade;
   bool _chunked;
 
   bool _noMessageBody = false;
   int _remainingContent = -1;
 
   _HttpHeaders _headers;
 
   // The current incoming connection.
   _HttpIncoming _incoming;
-  StreamSubscription<List<int>> _socketSubscription;
+  StreamSubscription _socketSubscription;
   bool _paused = true;
   bool _bodyPaused = false;
   StreamController<_HttpIncoming> _controller;
   StreamController<List<int>> _bodyController;
 
   factory _HttpParser.requestParser() {
     return new _HttpParser._(true);
   }
 
   factory _HttpParser.responseParser() {
@@ skipping 782 matching lines @@
     }
   }
 
   void _reportError(error, [stackTrace]) {
     if (_socketSubscription != null) _socketSubscription.cancel();
     _state = _State.FAILURE;
     _controller.addError(error, stackTrace);
     _controller.close();
   }
 }