Make new StreamController be async by default.

sdk/lib/io/http_parser.dart

Index: sdk/lib/io/http_parser.dart
diff --git a/sdk/lib/io/http_parser.dart b/sdk/lib/io/http_parser.dart
index b7aabd2074e11d107cabed6e6646fd3c95b7dd77..24cf5265c3d13dbdd913b35892c439d172ce14ec 100644
--- a/sdk/lib/io/http_parser.dart
+++ b/sdk/lib/io/http_parser.dart
@@ -106,7 +106,7 @@ class _HttpDetachedIncoming extends Stream<List<int>> {
 
   _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,
@@ -194,7 +194,7 @@ class _HttpParser
   }
 
   _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;
@@ -882,7 +882,7 @@ class _HttpParser
     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);