Make StreamSubscription be the active part of a stream.

tests/standalone/io/http_body_test.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.
 
 import 'dart:io';
 import 'dart:utf';
 
 import 'package:expect/expect.dart';
 
 void testHttpClientResponseBody() {
@@ skipping 150 matching lines @@
             if (shouldFail) {
               Expect.equals(HttpStatus.BAD_REQUEST, response.statusCode);
             }
             response.fold(null, (x, y) {});
             client.close();
             server.close();
           });
     });
   }
 
-  test("text/plain", "body".codeUnits, "body", "text");
-  test("text/plain; charset=utf-8",
-       "body".codeUnits,
-       "body",
-       "text");
-  test("text/plain; charset=utf-8", [42], "*", "text");
-  test("text/plain; charset=us-ascii", [142], "?", "text");
-  test("text/plain; charset=utf-8",
-       [142],
-       new String.fromCharCodes([UNICODE_REPLACEMENT_CHARACTER_CODEPOINT]),
-       "text");
-
-  test("application/json",
-       '{"val": 5}'.codeUnits,
-       { "val" : 5 },
-       "json");
-  test("application/json",
-       '{ bad json }'.codeUnits,
-       null,
-       "json",
-       shouldFail: true);
-
-  test(null, "body".codeUnits, "body".codeUnits, "binary");
+//  test("text/plain", "body".codeUnits, "body", "text");

[Anders Johnsen, 2013/05/22 13:07:08]

No :)

[Lasse Reichstein Nielsen, 2013/05/24 06:02:49]

Aaah, please?
The commented out tests were the ones that didn't fail during debugging, so
maybe I should reenable them :)

+//  test("text/plain; charset=utf-8",
+//       "body".codeUnits,
+//       "body",
+//       "text");
+//  test("text/plain; charset=utf-8", [42], "*", "text");
+//  test("text/plain; charset=us-ascii", [142], "?", "text");
+//  test("text/plain; charset=utf-8",
+//       [142],
+//       new String.fromCharCodes([UNICODE_REPLACEMENT_CHARACTER_CODEPOINT]),
+//       "text");
+//
+//  test("application/json",
+//       '{"val": 5}'.codeUnits,
+//       { "val" : 5 },
+//       "json");
+//  test("application/json",
+//       '{ bad json }'.codeUnits,
+//       null,
+//       "json",
+//       shouldFail: true);
+//
+//  test(null, "body".codeUnits, "body".codeUnits, "binary");
 
   test("multipart/form-data; boundary=AaB03x",
        '''
 --AaB03x\r
 Content-Disposition: form-data; name="name"\r
 \r
 Larry\r
 --AaB03x--\r\n'''.codeUnits,
        { "name": "Larry" },
        "form");
+return;

[Anders Johnsen, 2013/05/22 13:07:08]

No :)

[Lasse Reichstein Nielsen, 2013/05/24 06:02:49]

Done.

 
   test("multipart/form-data; boundary=AaB03x",
        '''
 --AaB03x\r
 Content-Disposition: form-data; name="files"; filename="myfile"\r
 Content-Type: application/octet-stream\r
 \r
 File content\r
 --AaB03x--\r\n'''.codeUnits,
        { "files": { 'filename': 'myfile',
@@ skipping 99 matching lines @@
        { 'name' : 'ȤȤ' },
        "form");
 
   test('application/x-www-form-urlencoded',
        'name=%C8%A4%C8%A4'.codeUnits,
        { 'name' : 'ȤȤ' },
        "form");
 }
 
 void main() {
-  testHttpClientResponseBody();
+//  testHttpClientResponseBody();

[Anders Johnsen, 2013/05/22 13:07:08]

No :)

   testHttpServerRequestBody();
 }