Reapply "Add onClosed callbacks to HTTP output streams""

tests/standalone/io/http_stream_close_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.
+//

[Mads Ager (google), 2013/01/11 12:09:12]

Remove this line?

+
+import "dart:io";
+import "dart:uri";
+
+main() {
+  bool serverOnClosed = false;
+  bool clientOnClosed = false;
+  bool requestOnClosed = false;
+
+  var server = new HttpServer();
+  var client = new HttpClient();
+
+  checkDone() {
+    if (serverOnClosed && clientOnClosed && requestOnClosed) {
+      server.close();
+      client.shutdown();
+    }
+  }
+
+  server.listen("127.0.0.1", 0);
+  server.defaultRequestHandler = (request, response) {
+    request.inputStream.onData = request.inputStream.read;
+    request.inputStream.onClosed = () {
+      response.outputStream.onClosed = () {
+        serverOnClosed = true;
+        checkDone();
+      };
+      response.outputStream.writeString("hello!");
+      response.outputStream.close();
+    };
+  };
+
+  var connection = client.postUrl(new Uri.fromString("http://127.0.0.1:${server.port}"));

[Mads Ager (google), 2013/01/11 12:09:12]

Line line.

+  connection.onError = (e) => throw e;
+  connection.onRequest = (request) {
+    request.contentLength = "hello!".length;
+    request.outputStream.onError = (e) => throw e;
+    request.outputStream.onClosed = () {
+      clientOnClosed = true;
+      checkDone();
+    };
+    request.outputStream.writeString("hello!");
+    request.outputStream.close();
+  };
+  connection.onResponse = (response) {
+    response.inputStream.onData = response.inputStream.read;
+    response.inputStream.onClosed = () {
+      requestOnClosed = true;
+      checkDone();
+    };
+  };
+}