Index: samples/chat/chat_stress_client.dart |
diff --git a/samples/chat/chat_stress_client.dart b/samples/chat/chat_stress_client.dart |
index c5c156703f343874e4e4c3f5829d5d9d72bbfd8f..0a50738db514a3eee32e8c380e3d0764a1e30e6a 100644 |
--- a/samples/chat/chat_stress_client.dart |
+++ b/samples/chat/chat_stress_client.dart |
@@ -55,15 +55,15 @@ class ChatStressClient { |
leaveRequest["request"] = "leave"; |
leaveRequest["sessionId"] = sessionId; |
HttpClientConnection conn = httpClient.post("127.0.0.1", port, "/leave"); |
- conn.requestHandler = (HttpClientRequest request) { |
+ conn.onRequest = (HttpClientRequest request) { |
request.writeString(JSON.stringify(leaveRequest)); |
request.outputStream.close(); |
}; |
- conn.responseHandler = (HttpClientResponse response) { |
+ conn.onResponse = (HttpClientResponse response) { |
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 = () { |
leaveResponseHandler(response, body.toString()); |
}; |
}; |
@@ -85,15 +85,15 @@ class ChatStressClient { |
messageRequest["nextMessage"] = receiveMessageCount; |
messageRequest["maxMessages"] = 100; |
HttpClientConnection conn = httpClient.post("127.0.0.1", port, "/receive"); |
- conn.requestHandler = (HttpClientRequest request) { |
+ conn.onRequest = (HttpClientRequest request) { |
request.writeString(JSON.stringify(messageRequest)); |
request.outputStream.close(); |
}; |
- conn.responseHandler = (HttpClientResponse response) { |
+ conn.onResponse = (HttpClientResponse response) { |
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 = () { |
receiveResponseHandler(response, body.toString()); |
}; |
}; |
@@ -122,15 +122,15 @@ class ChatStressClient { |
messageRequest["sessionId"] = sessionId; |
messageRequest["message"] = "message " + sendMessageCount; |
HttpClientConnection conn = httpClient.post("127.0.0.1", port, "/message"); |
- conn.requestHandler = (HttpClientRequest request) { |
+ conn.onRequest = (HttpClientRequest request) { |
request.writeString(JSON.stringify(messageRequest)); |
request.outputStream.close(); |
}; |
- conn.responseHandler = (HttpClientResponse response) { |
+ conn.onResponse = (HttpClientResponse response) { |
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 = () { |
sendResponseHandler(response, body.toString()); |
}; |
}; |
@@ -152,15 +152,15 @@ class ChatStressClient { |
joinRequest["request"] = "join"; |
joinRequest["handle"] = "test1"; |
HttpClientConnection conn = httpClient.post("127.0.0.1", port, "/join"); |
- conn.requestHandler = (HttpClientRequest request) { |
+ conn.onRequest = (HttpClientRequest request) { |
request.writeString(JSON.stringify(joinRequest)); |
request.outputStream.close(); |
}; |
- conn.responseHandler = (HttpClientResponse response) { |
+ conn.onResponse = (HttpClientResponse response) { |
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 = () { |
joinResponseHandler(response, body.toString()); |
}; |
}; |