Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(262)

Unified Diff: tests/standalone/src/HttpTest.dart

Issue 9500002: Rename blahHandler to onBlah throughout dart:io. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Renaming Created 8 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: tests/standalone/src/HttpTest.dart
diff --git a/tests/standalone/src/HttpTest.dart b/tests/standalone/src/HttpTest.dart
index df2c2c38385b2ea12ad5fd42d7364acab85d83f6..e21d5383b28ea34ae6eebb8aa937676d41fd9a72 100644
--- a/tests/standalone/src/HttpTest.dart
+++ b/tests/standalone/src/HttpTest.dart
@@ -102,8 +102,8 @@ class TestServer extends Isolate {
// Echo the request content back to the response.
void _zeroToTenHandler(HttpRequest request, HttpResponse response) {
Expect.equals("GET", request.method);
- request.inputStream.dataHandler = () {};
- request.inputStream.closeHandler = () {
+ request.inputStream.onData = () {};
+ request.inputStream.onClosed = () {
response.writeString("01234567890");
response.outputStream.close();
};
@@ -133,7 +133,7 @@ class TestServer extends Isolate {
_server = new HttpServer();
try {
_server.listen("127.0.0.1", 0);
- _server.requestHandler = (HttpRequest req, HttpResponse rsp) {
+ _server.onRequest = (HttpRequest req, HttpResponse rsp) {
_requestReceivedHandler(req, rsp);
};
replyTo.send(new TestServerStatus.started(_server.port), null);
@@ -180,12 +180,12 @@ void testGET() {
HttpClient httpClient = new HttpClient();
HttpClientConnection conn =
httpClient.get("127.0.0.1", port, "/0123456789");
- conn.responseHandler = (HttpClientResponse response) {
+ conn.onResponse = (HttpClientResponse response) {
Expect.equals(HttpStatus.OK, response.statusCode);
StringInputStream stream = new StringInputStream(response.inputStream);
StringBuffer body = new StringBuffer();
- stream.dataHandler = () => body.add(stream.read());
- stream.closeHandler = () {
+ stream.onData = () => body.add(stream.read());
+ stream.onClosed = () {
Expect.equals("01234567890", body.toString());
httpClient.shutdown();
testServerMain.shutdown();
@@ -208,7 +208,7 @@ void testPOST(bool chunkedEncoding) {
void sendRequest() {
HttpClientConnection conn =
httpClient.post("127.0.0.1", port, "/echo");
- conn.requestHandler = (HttpClientRequest request) {
+ conn.onRequest = (HttpClientRequest request) {
if (chunkedEncoding) {
request.writeString(data.substring(0, 10));
request.writeString(data.substring(10, data.length));
@@ -218,12 +218,12 @@ void testPOST(bool chunkedEncoding) {
}
request.outputStream.close();
};
- conn.responseHandler = (HttpClientResponse response) {
+ conn.onResponse = (HttpClientResponse response) {
Expect.equals(HttpStatus.OK, response.statusCode);
StringInputStream stream = new StringInputStream(response.inputStream);
StringBuffer body = new StringBuffer();
- stream.dataHandler = () => body.add(stream.read());
- stream.closeHandler = () {
+ stream.onData = () => body.add(stream.read());
+ stream.onClosed = () {
Expect.equals(data, body.toString());
count++;
if (count < kMessageCount) {
@@ -259,7 +259,7 @@ void testReadInto(bool chunkedEncoding) {
void sendRequest() {
HttpClientConnection conn =
httpClient.post("127.0.0.1", port, "/echo");
- conn.requestHandler = (HttpClientRequest request) {
+ conn.onRequest = (HttpClientRequest request) {
if (chunkedEncoding) {
request.writeString(data.substring(0, 10));
request.writeString(data.substring(10, data.length));
@@ -269,16 +269,16 @@ void testReadInto(bool chunkedEncoding) {
}
request.outputStream.close();
};
- conn.responseHandler = (HttpClientResponse response) {
+ conn.onResponse = (HttpClientResponse response) {
Expect.equals(HttpStatus.OK, response.statusCode);
InputStream stream = response.inputStream;
List<int> body = new List<int>();
- stream.dataHandler = () {
+ stream.onData = () {
List tmp = new List(3);
int bytes = stream.readInto(tmp);
body.addAll(tmp.getRange(0, bytes));
};
- stream.closeHandler = () {
+ stream.onClosed = () {
Expect.equals(data, new String.fromCharCodes(body));
count++;
if (count < kMessageCount) {
@@ -314,7 +314,7 @@ void testReadShort(bool chunkedEncoding) {
void sendRequest() {
HttpClientConnection conn =
httpClient.post("127.0.0.1", port, "/echo");
- conn.requestHandler = (HttpClientRequest request) {
+ conn.onRequest = (HttpClientRequest request) {
if (chunkedEncoding) {
request.writeString(data.substring(0, 10));
request.writeString(data.substring(10, data.length));
@@ -324,15 +324,15 @@ void testReadShort(bool chunkedEncoding) {
}
request.outputStream.close();
};
- conn.responseHandler = (HttpClientResponse response) {
+ conn.onResponse = (HttpClientResponse response) {
Expect.equals(HttpStatus.OK, response.statusCode);
InputStream stream = response.inputStream;
List<int> body = new List<int>();
- stream.dataHandler = () {
+ stream.onData = () {
List tmp = stream.read(2);
body.addAll(tmp);
};
- stream.closeHandler = () {
+ stream.onClosed = () {
Expect.equals(data, new String.fromCharCodes(body));
count++;
if (count < kMessageCount) {
@@ -362,7 +362,7 @@ void test404() {
HttpClient httpClient = new HttpClient();
HttpClientConnection conn =
httpClient.get("127.0.0.1", port, "/thisisnotfound");
- conn.responseHandler = (HttpClientResponse response) {
+ conn.onResponse = (HttpClientResponse response) {
Expect.equals(HttpStatus.NOT_FOUND, response.statusCode);
httpClient.shutdown();
testServerMain.shutdown();

Powered by Google App Engine
This is Rietveld 408576698