| 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 |