Add support for controlling HttpResponse.bufferOutput to shelf_io.

test/shelf_io_test.dart

 // Copyright (c) 2014, 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.
 
 library shelf_io_test;
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:io';
 
 import 'package:http/http.dart' as http;
 import 'package:http_parser/http_parser.dart' as parser;
+import 'package:scheduled_test/scheduled_stream.dart';
 import 'package:scheduled_test/scheduled_test.dart';
 import 'package:shelf/shelf.dart';
 import 'package:shelf/shelf_io.dart' as shelf_io;
 
 import 'test_util.dart';
 
 void main() {
   test('sync handler returns a value to the client', () {
     _scheduleServer(syncHandler);
 
@@ skipping 301 matching lines @@
       _scheduleServer((request) {
         return new Response.ok('test',
             headers: {HttpHeaders.SERVER: 'myServer'});
       });
 
       return _scheduleGet().then((response) {
         expect(response.headers, containsPair(HttpHeaders.SERVER, 'myServer'));
       });
     });
   });
+
+  test('respects the "shelf.io.buffer_output" context parameter', () {
+    var controller = new StreamController();
+    _scheduleServer((request) {
+      controller.add("Hello, ");
+
+      return new Response.ok(UTF8.encoder.bind(controller.stream),
+          context: {"shelf.io.buffer_output": false});
+    });
+
+    schedule(() {
+      var request = new http.Request(
+          "GET", Uri.parse('http://localhost:$_serverPort/'));
+
+      return request.send().then((response) {
+        var stream = new ScheduledStream(UTF8.decoder.bind(response.stream));
+
+        return stream.next().then((data) {
+          expect(data, equals("Hello, "));
+          controller.add("world!");
+          return stream.next();
+        }).then((data) {
+          expect(data, equals("world!"));
+          controller.close();
+          expect(stream.hasNext, completion(isFalse));
+        });
+      });
+    });
+  });
 }
 
 int _serverPort;
 
 Future _scheduleServer(Handler handler) {
   return schedule(() => shelf_io.serve(handler, 'localhost', 0).then((server) {
     currentSchedule.onComplete.schedule(() {
       _serverPort = null;
       return server.close(force: true);
     });
@@ skipping 14 matching lines @@
   return schedule(() {
     var request =
         new http.Request('POST', Uri.parse('http://localhost:$_serverPort/'));
 
     if (headers != null) request.headers.addAll(headers);
     if (body != null) request.body = body;
 
     return request.send();
   });
 }