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

Unified Diff: samples/chat/chat_server_lib.dart

Issue 9500002: Rename blahHandler to onBlah throughout dart:io. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Address comments. 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
« no previous file with comments | « runtime/bin/string_stream.dart ('k') | samples/chat/chat_stress_client.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: samples/chat/chat_server_lib.dart
diff --git a/samples/chat/chat_server_lib.dart b/samples/chat/chat_server_lib.dart
index 6dc550043a1917075568df373c150344ea56475d..833755cb4cf55b2545f32f0b0f97c9a7c86a7ef0 100644
--- a/samples/chat/chat_server_lib.dart
+++ b/samples/chat/chat_server_lib.dart
@@ -409,8 +409,8 @@ class IsolatedServer extends Isolate {
void _joinHandler(HttpRequest request, HttpResponse response) {
StringBuffer body = new StringBuffer();
StringInputStream input = new StringInputStream(request.inputStream);
- input.dataHandler = () => body.add(input.read());
- input.closeHandler = () {
+ input.onData = () => body.add(input.read());
+ input.onClosed = () {
String data = body.toString();
if (data != null) {
var requestData = JSON.parse(data);
@@ -443,8 +443,8 @@ class IsolatedServer extends Isolate {
void _leaveHandler(HttpRequest request, HttpResponse response) {
StringBuffer body = new StringBuffer();
StringInputStream input = new StringInputStream(request.inputStream);
- input.dataHandler = () => body.add(input.read());
- input.closeHandler = () {
+ input.onData = () => body.add(input.read());
+ input.onClosed = () {
String data = body.toString();
var requestData = JSON.parse(data);
if (requestData["request"] == "leave") {
@@ -473,8 +473,8 @@ class IsolatedServer extends Isolate {
void _messageHandler(HttpRequest request, HttpResponse response) {
StringBuffer body = new StringBuffer();
StringInputStream input = new StringInputStream(request.inputStream);
- input.dataHandler = () => body.add(input.read());
- input.closeHandler = () {
+ input.onData = () => body.add(input.read());
+ input.onClosed = () {
String data = body.toString();
_messageCount++;
_messageRate.record(1);
@@ -510,8 +510,8 @@ class IsolatedServer extends Isolate {
void _receiveHandler(HttpRequest request, HttpResponse response) {
StringBuffer body = new StringBuffer();
StringInputStream input = new StringInputStream(request.inputStream);
- input.dataHandler = () => body.add(input.read());
- input.closeHandler = () {
+ input.onData = () => body.add(input.read());
+ input.onClosed = () {
String data = body.toString();
var requestData = JSON.parse(data);
if (requestData["request"] == "receive") {
@@ -587,7 +587,7 @@ class IsolatedServer extends Isolate {
_server = new HttpServer();
try {
_server.listen(_host, _port, backlog: message.backlog);
- _server.requestHandler = (HttpRequest req, HttpResponse rsp) =>
+ _server.onRequest = (HttpRequest req, HttpResponse rsp) =>
_requestReceivedHandler(req, rsp);
replyTo.send(new ChatServerStatus.started(_server.port), null);
_loggingTimer = new Timer.repeating(_handleLogging, 1000);
« no previous file with comments | « runtime/bin/string_stream.dart ('k') | samples/chat/chat_stress_client.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698