OLD | NEW |
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 import "dart:io"; | 5 import "dart:io"; |
6 import "dart:isolate"; | 6 import "dart:isolate"; |
7 import "dart:scalarlist"; | 7 import "dart:scalarlist"; |
8 | 8 |
9 void testClientRequest(void handler(request)) { | 9 void testClientRequest(void handler(request)) { |
10 HttpServer.bind().then((server) { | 10 HttpServer.bind().then((server) { |
(...skipping 28 matching lines...) Expand all Loading... |
39 Expect.equals(request, req); | 39 Expect.equals(request, req); |
40 }); | 40 }); |
41 return request.response; | 41 return request.response; |
42 }); | 42 }); |
43 } | 43 } |
44 | 44 |
45 void testBadResponseAdd() { | 45 void testBadResponseAdd() { |
46 testClientRequest((request) { | 46 testClientRequest((request) { |
47 var port = new ReceivePort(); | 47 var port = new ReceivePort(); |
48 request.contentLength = 0; | 48 request.contentLength = 0; |
49 request.add([0]); | 49 request.writeBytes([0]); |
50 request.done.catchError((error) { | 50 request.done.catchError((error) { |
51 port.close(); | 51 port.close(); |
52 }, test: (e) => e is HttpException); | 52 }, test: (e) => e is HttpException); |
53 return request.response; | 53 return request.response; |
54 }); | 54 }); |
55 | 55 |
56 testClientRequest((request) { | 56 testClientRequest((request) { |
57 var port = new ReceivePort(); | 57 var port = new ReceivePort(); |
58 request.contentLength = 5; | 58 request.contentLength = 5; |
59 request.add([0, 0, 0]); | 59 request.writeBytes([0, 0, 0]); |
60 request.add([0, 0, 0]); | 60 request.writeBytes([0, 0, 0]); |
61 request.done.catchError((error) { | 61 request.done.catchError((error) { |
62 port.close(); | 62 port.close(); |
63 }, test: (e) => e is HttpException); | 63 }, test: (e) => e is HttpException); |
64 return request.response; | 64 return request.response; |
65 }); | 65 }); |
66 | 66 |
67 testClientRequest((request) { | 67 testClientRequest((request) { |
68 var port = new ReceivePort(); | 68 var port = new ReceivePort(); |
69 request.contentLength = 0; | 69 request.contentLength = 0; |
70 request.add(new Uint8List(64 * 1024)); | 70 request.writeBytes(new Uint8List(64 * 1024)); |
71 request.add(new Uint8List(64 * 1024)); | 71 request.writeBytes(new Uint8List(64 * 1024)); |
72 request.add(new Uint8List(64 * 1024)); | 72 request.writeBytes(new Uint8List(64 * 1024)); |
73 request.done.catchError((error) { | 73 request.done.catchError((error) { |
74 port.close(); | 74 port.close(); |
75 }, test: (e) => e is HttpException); | 75 }, test: (e) => e is HttpException); |
76 return request.response; | 76 return request.response; |
77 }); | 77 }); |
78 } | 78 } |
79 | 79 |
80 void testBadResponseClose() { | 80 void testBadResponseClose() { |
81 testClientRequest((request) { | 81 testClientRequest((request) { |
82 var port = new ReceivePort(); | 82 var port = new ReceivePort(); |
83 request.contentLength = 5; | 83 request.contentLength = 5; |
84 request.close(); | 84 request.close(); |
85 request.done.catchError((error) { | 85 request.done.catchError((error) { |
86 port.close(); | 86 port.close(); |
87 }, test: (e) => e is HttpException); | 87 }, test: (e) => e is HttpException); |
88 return request.response; | 88 return request.response; |
89 }); | 89 }); |
90 | 90 |
91 testClientRequest((request) { | 91 testClientRequest((request) { |
92 var port = new ReceivePort(); | 92 var port = new ReceivePort(); |
93 request.contentLength = 5; | 93 request.contentLength = 5; |
94 request.add([0]); | 94 request.writeBytes([0]); |
95 request.close(); | 95 request.close(); |
96 request.done.catchError((error) { | 96 request.done.catchError((error) { |
97 port.close(); | 97 port.close(); |
98 }, test: (e) => e is HttpException); | 98 }, test: (e) => e is HttpException); |
99 return request.response; | 99 return request.response; |
100 }); | 100 }); |
101 } | 101 } |
102 | 102 |
103 void main() { | 103 void main() { |
104 testResponseDone(); | 104 testResponseDone(); |
105 testBadResponseAdd(); | 105 testBadResponseAdd(); |
106 testBadResponseClose(); | 106 testBadResponseClose(); |
107 } | 107 } |
OLD | NEW |