OLD | NEW |
1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 library http_multi_server.test; | 5 library http_multi_server.test; |
6 | 6 |
7 import 'dart:async'; | 7 import 'dart:async'; |
8 import 'dart:io'; | 8 import 'dart:io'; |
9 | 9 |
10 import 'package:http/http.dart' as http; | 10 import 'package:http/http.dart' as http; |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
53 | 53 |
54 expect(_get(subServer2).then((response) { | 54 expect(_get(subServer2).then((response) { |
55 expect(response.headers['server'], equals("http_multi_server test")); | 55 expect(response.headers['server'], equals("http_multi_server test")); |
56 }), completes); | 56 }), completes); |
57 | 57 |
58 expect(_get(subServer3).then((response) { | 58 expect(_get(subServer3).then((response) { |
59 expect(response.headers['server'], equals("http_multi_server test")); | 59 expect(response.headers['server'], equals("http_multi_server test")); |
60 }), completes); | 60 }), completes); |
61 }); | 61 }); |
62 | 62 |
| 63 test("headers.set sets the value for all servers", () { |
| 64 multiServer.defaultResponseHeaders.set( |
| 65 "server", "http_multi_server test"); |
| 66 |
| 67 multiServer.listen((request) { |
| 68 request.response.write("got request"); |
| 69 request.response.close(); |
| 70 }); |
| 71 |
| 72 expect(_get(subServer1).then((response) { |
| 73 expect(response.headers['server'], equals("http_multi_server test")); |
| 74 }), completes); |
| 75 |
| 76 expect(_get(subServer2).then((response) { |
| 77 expect(response.headers['server'], equals("http_multi_server test")); |
| 78 }), completes); |
| 79 |
| 80 expect(_get(subServer3).then((response) { |
| 81 expect(response.headers['server'], equals("http_multi_server test")); |
| 82 }), completes); |
| 83 }); |
| 84 |
63 test("connectionsInfo sums the values for all servers", () { | 85 test("connectionsInfo sums the values for all servers", () { |
64 var pendingRequests = 0; | 86 var pendingRequests = 0; |
65 var awaitingResponseCompleter = new Completer(); | 87 var awaitingResponseCompleter = new Completer(); |
66 var sendResponseCompleter = new Completer(); | 88 var sendResponseCompleter = new Completer(); |
67 multiServer.listen((request) { | 89 multiServer.listen((request) { |
68 sendResponseCompleter.future.then((_) { | 90 sendResponseCompleter.future.then((_) { |
69 request.response.write("got request"); | 91 request.response.write("got request"); |
70 request.response.close(); | 92 request.response.close(); |
71 }); | 93 }); |
72 | 94 |
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
119 | 141 |
120 /// Makes a GET request to the root of [server] and returns the response. | 142 /// Makes a GET request to the root of [server] and returns the response. |
121 Future<http.Response> _get(HttpServer server) => http.get(_urlFor(server)); | 143 Future<http.Response> _get(HttpServer server) => http.get(_urlFor(server)); |
122 | 144 |
123 /// Makes a GET request to the root of [server] and returns the response body. | 145 /// Makes a GET request to the root of [server] and returns the response body. |
124 Future<String> _read(HttpServer server) => http.read(_urlFor(server)); | 146 Future<String> _read(HttpServer server) => http.read(_urlFor(server)); |
125 | 147 |
126 /// Returns the URL for the root of [server]. | 148 /// Returns the URL for the root of [server]. |
127 String _urlFor(HttpServer server) => | 149 String _urlFor(HttpServer server) => |
128 "http://${server.address.host}:${server.port}/"; | 150 "http://${server.address.host}:${server.port}/"; |
OLD | NEW |