Make new StreamController be async by default.

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 88 matching lines @@
   StreamController<List<int>> controller;
   final StreamSubscription subscription;
 
   List<int> carryOverData;
   bool paused;
 
   Completer resumeCompleter;
 
   _HttpDetachedIncoming(StreamSubscription this.subscription,
                         List<int> this.carryOverData) {
-    controller = new StreamController<List<int>>(
+    controller = new StreamController<List<int>>(sync: true,

[floitsch, 2013/05/30 12:13:48]

move to next line.

[Lasse Reichstein Nielsen, 2013/05/31 05:51:59]

Done.

         onListen: resume,
         onPause: pause,
         onResume: resume,
         onCancel: () => subscription.cancel());
     if (subscription == null) {
       // Socket was already closed.
       if (carryOverData != null) controller.add(carryOverData);
       controller.close();
     } else {
       pause();
@@ skipping 67 matching lines @@
 
   factory _HttpParser.requestParser() {
     return new _HttpParser._(true);
   }
 
   factory _HttpParser.responseParser() {
     return new _HttpParser._(false);
   }
 
   _HttpParser._(this._requestParser) {
-    _controller = new StreamController<_HttpIncoming>(
+    _controller = new StreamController<_HttpIncoming>(sync: true,

[floitsch, 2013/05/30 12:13:48]

move to next line.

[Lasse Reichstein Nielsen, 2013/05/31 05:51:59]

Done.

           onListen: () {
             _socketSubscription.resume();
             _paused = false;
           },
           onPause: () {
             _paused = true;
             _pauseStateChanged();
           },
           onResume: () {
             _paused = false;
@@ skipping 667 matching lines @@
     } else {
       throw new HttpParserException("Failed to parse HTTP");
     }
   }
 
   void _createIncoming(int transferLength) {
     assert(_incoming == null);
     assert(_bodyController == null);
     assert(!_bodyPaused);
     var incoming;
-    _bodyController = new StreamController<List<int>>(
+    _bodyController = new StreamController<List<int>>(sync: true,

[floitsch, 2013/05/30 12:13:48]

ditto.

[Lasse Reichstein Nielsen, 2013/05/31 05:51:59]

Done.

         onListen: () {
           if (incoming != _incoming) return;
           assert(_bodyPaused);
           _bodyPaused = false;
           _pauseStateChanged();
         },
         onPause: () {
           if (incoming != _incoming) return;
           assert(!_bodyPaused);
           _bodyPaused = true;
@@ skipping 89 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;
 }