Make StreamSubscription be the active part of a stream.

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 910 matching lines @@
     _incoming = null;
     if (_bodyController != null) {
       _bodyController.close();
       _bodyController = null;
     }
     _bodyPaused = false;
     _pauseStateChanged();
   }
 
   void _pauseStateChanged() {
-    void update(bool pause) {
-      if (pause && !_socketSubscription.isPaused) {
-        _socketSubscription.pause();
-      } else if (!pause && _socketSubscription.isPaused) {
-        _socketSubscription.resume();
-      }
-    }
-
     if (_incoming != null) {
       if (!_bodyPaused && !_parserCalled) {
         _parse();
       }
     } else {
       if (!_paused && !_parserCalled) {
         _parse();
       }
     }
   }
@@ skipping 42 matching lines @@
   StreamController<_HttpIncoming> _controller;
   StreamController<List<int>> _bodyController;
 }
 
 
 class HttpParserException implements Exception {
   const HttpParserException([String this.message = ""]);
   String toString() => "HttpParserException: $message";
   final String message;
 }