@@ -11,127 +11,127 @@ import 'package:http_multi_server/src/utils.dart';
11
11
import 'package:test/test.dart' ;
12
12
13
13
void main () {
14
- group (" with multiple HttpServers" , () {
14
+ group (' with multiple HttpServers' , () {
15
15
var multiServer;
16
16
HttpServer subServer1;
17
17
HttpServer subServer2;
18
18
HttpServer subServer3;
19
19
setUp (() {
20
20
return Future .wait ([
21
- HttpServer .bind (" localhost" , 0 ).then ((server) => subServer1 = server),
22
- HttpServer .bind (" localhost" , 0 ).then ((server) => subServer2 = server),
23
- HttpServer .bind (" localhost" , 0 ).then ((server) => subServer3 = server)
21
+ HttpServer .bind (' localhost' , 0 ).then ((server) => subServer1 = server),
22
+ HttpServer .bind (' localhost' , 0 ).then ((server) => subServer2 = server),
23
+ HttpServer .bind (' localhost' , 0 ).then ((server) => subServer3 = server)
24
24
]).then ((servers) => multiServer = HttpMultiServer (servers));
25
25
});
26
26
27
27
tearDown (() => multiServer.close ());
28
28
29
- test (" listen listens to all servers" , () {
29
+ test (' listen listens to all servers' , () {
30
30
multiServer.listen ((request) {
31
- request.response.write (" got request" );
31
+ request.response.write (' got request' );
32
32
request.response.close ();
33
33
});
34
34
35
- expect (_read (subServer1), completion (equals (" got request" )));
36
- expect (_read (subServer2), completion (equals (" got request" )));
37
- expect (_read (subServer3), completion (equals (" got request" )));
35
+ expect (_read (subServer1), completion (equals (' got request' )));
36
+ expect (_read (subServer2), completion (equals (' got request' )));
37
+ expect (_read (subServer3), completion (equals (' got request' )));
38
38
});
39
39
40
- test (" serverHeader= sets the value for all servers" , () {
41
- multiServer.serverHeader = " http_multi_server test" ;
40
+ test (' serverHeader= sets the value for all servers' , () {
41
+ multiServer.serverHeader = ' http_multi_server test' ;
42
42
43
43
multiServer.listen ((request) {
44
- request.response.write (" got request" );
44
+ request.response.write (' got request' );
45
45
request.response.close ();
46
46
});
47
47
48
48
expect (
49
49
_get (subServer1).then ((response) {
50
50
expect (
51
- response.headers['server' ], equals (" http_multi_server test" ));
51
+ response.headers['server' ], equals (' http_multi_server test' ));
52
52
}),
53
53
completes);
54
54
55
55
expect (
56
56
_get (subServer2).then ((response) {
57
57
expect (
58
- response.headers['server' ], equals (" http_multi_server test" ));
58
+ response.headers['server' ], equals (' http_multi_server test' ));
59
59
}),
60
60
completes);
61
61
62
62
expect (
63
63
_get (subServer3).then ((response) {
64
64
expect (
65
- response.headers['server' ], equals (" http_multi_server test" ));
65
+ response.headers['server' ], equals (' http_multi_server test' ));
66
66
}),
67
67
completes);
68
68
});
69
69
70
- test (" autoCompress= sets the value for all servers" , () {
70
+ test (' autoCompress= sets the value for all servers' , () {
71
71
multiServer.autoCompress = true ;
72
72
73
73
multiServer.listen ((request) {
74
- request.response.write (" got request" );
74
+ request.response.write (' got request' );
75
75
request.response.close ();
76
76
});
77
77
78
78
expect (
79
79
_get (subServer1).then ((response) {
80
- expect (response.headers['content-encoding' ], equals (" gzip" ));
80
+ expect (response.headers['content-encoding' ], equals (' gzip' ));
81
81
}),
82
82
completes);
83
83
84
84
expect (
85
85
_get (subServer2).then ((response) {
86
- expect (response.headers['content-encoding' ], equals (" gzip" ));
86
+ expect (response.headers['content-encoding' ], equals (' gzip' ));
87
87
}),
88
88
completes);
89
89
90
90
expect (
91
91
_get (subServer3).then ((response) {
92
- expect (response.headers['content-encoding' ], equals (" gzip" ));
92
+ expect (response.headers['content-encoding' ], equals (' gzip' ));
93
93
}),
94
94
completes);
95
95
});
96
96
97
- test (" headers.set sets the value for all servers" , () {
97
+ test (' headers.set sets the value for all servers' , () {
98
98
multiServer.defaultResponseHeaders
99
- .set (" server" , " http_multi_server test" );
99
+ .set (' server' , ' http_multi_server test' );
100
100
101
101
multiServer.listen ((request) {
102
- request.response.write (" got request" );
102
+ request.response.write (' got request' );
103
103
request.response.close ();
104
104
});
105
105
106
106
expect (
107
107
_get (subServer1).then ((response) {
108
108
expect (
109
- response.headers['server' ], equals (" http_multi_server test" ));
109
+ response.headers['server' ], equals (' http_multi_server test' ));
110
110
}),
111
111
completes);
112
112
113
113
expect (
114
114
_get (subServer2).then ((response) {
115
115
expect (
116
- response.headers['server' ], equals (" http_multi_server test" ));
116
+ response.headers['server' ], equals (' http_multi_server test' ));
117
117
}),
118
118
completes);
119
119
120
120
expect (
121
121
_get (subServer3).then ((response) {
122
122
expect (
123
- response.headers['server' ], equals (" http_multi_server test" ));
123
+ response.headers['server' ], equals (' http_multi_server test' ));
124
124
}),
125
125
completes);
126
126
});
127
127
128
- test (" connectionsInfo sums the values for all servers" , () {
128
+ test (' connectionsInfo sums the values for all servers' , () {
129
129
var pendingRequests = 0 ;
130
130
var awaitingResponseCompleter = Completer ();
131
131
var sendResponseCompleter = Completer ();
132
132
multiServer.listen ((request) {
133
133
sendResponseCompleter.future.then ((_) {
134
- request.response.write (" got request" );
134
+ request.response.write (' got request' );
135
135
request.response.close ();
136
136
});
137
137
@@ -156,83 +156,83 @@ void main() {
156
156
});
157
157
});
158
158
159
- group (" HttpMultiServer.loopback" , () {
159
+ group (' HttpMultiServer.loopback' , () {
160
160
var server;
161
161
setUp (() {
162
162
return HttpMultiServer .loopback (0 ).then ((s) => server = s);
163
163
});
164
164
165
165
tearDown (() => server.close ());
166
166
167
- test (" listens on all localhost interfaces" , () async {
167
+ test (' listens on all localhost interfaces' , () async {
168
168
server.listen ((request) {
169
- request.response.write (" got request" );
169
+ request.response.write (' got request' );
170
170
request.response.close ();
171
171
});
172
172
173
173
if (await supportsIPv4) {
174
- expect (http.read (" http://127.0.0.1:${server .port }/" ),
175
- completion (equals (" got request" )));
174
+ expect (http.read (' http://127.0.0.1:${server .port }/' ),
175
+ completion (equals (' got request' )));
176
176
}
177
177
178
178
if (await supportsIPv6) {
179
- expect (http.read (" http://[::1]:${server .port }/" ),
180
- completion (equals (" got request" )));
179
+ expect (http.read (' http://[::1]:${server .port }/' ),
180
+ completion (equals (' got request' )));
181
181
}
182
182
});
183
183
});
184
184
185
- group (" HttpMultiServer.bind" , () {
185
+ group (' HttpMultiServer.bind' , () {
186
186
test ("listens on all localhost interfaces for 'localhost'" , () async {
187
- final server = await HttpMultiServer .bind (" localhost" , 0 );
187
+ final server = await HttpMultiServer .bind (' localhost' , 0 );
188
188
server.listen ((request) {
189
- request.response.write (" got request" );
189
+ request.response.write (' got request' );
190
190
request.response.close ();
191
191
});
192
192
193
193
if (await supportsIPv4) {
194
- expect (http.read (" http://127.0.0.1:${server .port }/" ),
195
- completion (equals (" got request" )));
194
+ expect (http.read (' http://127.0.0.1:${server .port }/' ),
195
+ completion (equals (' got request' )));
196
196
}
197
197
198
198
if (await supportsIPv6) {
199
- expect (http.read (" http://[::1]:${server .port }/" ),
200
- completion (equals (" got request" )));
199
+ expect (http.read (' http://[::1]:${server .port }/' ),
200
+ completion (equals (' got request' )));
201
201
}
202
202
});
203
203
204
204
test ("listens on all localhost interfaces for 'any'" , () async {
205
- final server = await HttpMultiServer .bind (" any" , 0 );
205
+ final server = await HttpMultiServer .bind (' any' , 0 );
206
206
server.listen ((request) {
207
- request.response.write (" got request" );
207
+ request.response.write (' got request' );
208
208
request.response.close ();
209
209
});
210
210
211
211
if (await supportsIPv4) {
212
- expect (http.read (" http://127.0.0.1:${server .port }/" ),
213
- completion (equals (" got request" )));
212
+ expect (http.read (' http://127.0.0.1:${server .port }/' ),
213
+ completion (equals (' got request' )));
214
214
}
215
215
216
216
if (await supportsIPv6) {
217
- expect (http.read (" http://[::1]:${server .port }/" ),
218
- completion (equals (" got request" )));
217
+ expect (http.read (' http://[::1]:${server .port }/' ),
218
+ completion (equals (' got request' )));
219
219
}
220
220
});
221
221
222
- test (" listens on specified hostname" , () async {
222
+ test (' listens on specified hostname' , () async {
223
223
final server = await HttpMultiServer .bind (InternetAddress .anyIPv4, 0 );
224
224
server.listen ((request) {
225
- request.response.write (" got request" );
225
+ request.response.write (' got request' );
226
226
request.response.close ();
227
227
});
228
228
229
229
if (await supportsIPv4) {
230
- expect (http.read (" http://127.0.0.1:${server .port }/" ),
231
- completion (equals (" got request" )));
230
+ expect (http.read (' http://127.0.0.1:${server .port }/' ),
231
+ completion (equals (' got request' )));
232
232
}
233
233
234
234
if (await supportsIPv6) {
235
- expect (http.read (" http://[::1]:${server .port }/" ),
235
+ expect (http.read (' http://[::1]:${server .port }/' ),
236
236
throwsA (isA <SocketException >()));
237
237
}
238
238
});
@@ -247,4 +247,4 @@ Future<String> _read(HttpServer server) => http.read(_urlFor(server));
247
247
248
248
/// Returns the URL for the root of [server] .
249
249
String _urlFor (HttpServer server) =>
250
- " http://${server .address .host }:${server .port }/" ;
250
+ ' http://${server .address .host }:${server .port }/' ;
0 commit comments