| Index: tests/standalone/io/http_stream_close_test.dart
|
| diff --git a/tests/standalone/io/http_stream_close_test.dart b/tests/standalone/io/http_stream_close_test.dart
|
| index f5d4aeb8450afde49a4e8132ac305f3c46f2e1a7..06b95727817cda10cb2dbcac742164f16059900b 100644
|
| --- a/tests/standalone/io/http_stream_close_test.dart
|
| +++ b/tests/standalone/io/http_stream_close_test.dart
|
| @@ -21,35 +21,31 @@ main() {
|
| }
|
|
|
| server.listen((request) {
|
| - request.listen(
|
| - (_) {},
|
| - onDone: () {
|
| - request.response.done.then((_) {
|
| - serverOnClosed = true;
|
| - checkDone();
|
| - });
|
| - request.response.write("hello!");
|
| - request.response.close();
|
| - });
|
| + request.listen((_) {}, onDone: () {
|
| + request.response.done.then((_) {
|
| + serverOnClosed = true;
|
| + checkDone();
|
| + });
|
| + request.response.write("hello!");
|
| + request.response.close();
|
| });
|
| + });
|
|
|
| - client.postUrl(Uri.parse("http://127.0.0.1:${server.port}"))
|
| + client
|
| + .postUrl(Uri.parse("http://127.0.0.1:${server.port}"))
|
| .then((request) {
|
| - request.contentLength = "hello!".length;
|
| - request.done.then((_) {
|
| - clientOnClosed = true;
|
| - checkDone();
|
| - });
|
| - request.write("hello!");
|
| - return request.close();
|
| - })
|
| - .then((response) {
|
| - response.listen(
|
| - (_) {},
|
| - onDone: () {
|
| - requestOnClosed = true;
|
| - checkDone();
|
| - });
|
| - });
|
| + request.contentLength = "hello!".length;
|
| + request.done.then((_) {
|
| + clientOnClosed = true;
|
| + checkDone();
|
| + });
|
| + request.write("hello!");
|
| + return request.close();
|
| + }).then((response) {
|
| + response.listen((_) {}, onDone: () {
|
| + requestOnClosed = true;
|
| + checkDone();
|
| + });
|
| + });
|
| });
|
| }
|
|
|