Rename blahHandler to onBlah throughout dart:io.

samples/chat/chat_server_lib.dart

 // Copyright (c) 2012, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 #library("chat_server");
 #import("dart:io");
 #import("dart:isolate");
 #import("dart:json");
 
 typedef void RequestHandler(HttpRequest request, HttpResponse response);
@@ skipping 391 matching lines @@
     response.contentLength = 0;
     response.outputStream.close();
   }
 
   // Join request:
   // { "request": "join",
   //   "handle": <handle> }
   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);
         if (requestData["request"] == "join") {
           String handle = requestData["handle"];
           if (handle != null) {
             // New user joining.
             User user = _topic._userJoined(handle);
 
             // Send response.
@@ skipping 12 matching lines @@
       }
     };
   }
 
   // Leave request:
   // { "request": "leave",
   //   "sessionId": <sessionId> }
   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") {
         String sessionId = requestData["sessionId"];
         if (sessionId != null) {
           // User leaving.
           _topic._userLeft(sessionId);
 
           // Send response.
           Map responseData = new Map();
           responseData["response"] = "leave";
           _sendJSONResponse(response, responseData);
         } else {
           _protocolError(request, response);
         }
       } else {
         _protocolError(request, response);
       }
     };
   }
 
   // Message request:
   // { "request": "message",
   //   "sessionId": <sessionId>,
   //   "message": <message> }
   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);
       var requestData = JSON.parse(data);
       if (requestData["request"] == "message") {
         String sessionId = requestData["sessionId"];
         if (sessionId != null) {
           // New message from user.
           bool success = _topic._userMessage(requestData);
 
@@ skipping 15 matching lines @@
   }
 
   // Receive request:
   // { "request": "receive",
   //   "sessionId": <sessionId>,
   //   "nextMessage": <nextMessage>,
   //   "maxMessages": <maxMesssages> }
   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") {
         String sessionId = requestData["sessionId"];
         int nextMessage = requestData["nextMessage"];
         int maxMessages = requestData["maxMessages"];
         if (sessionId != null && nextMessage != null) {
 
           void sendResponse(messages) {
             // Send response.
@@ skipping 55 matching lines @@
 
     this.port.receive((var message, SendPort replyTo) {
       if (message.isStart) {
         _host = message.host;
         _port = message.port;
         _logging = message.logging;
         replyTo.send(new ChatServerStatus.starting(), null);
         _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);
         } catch (var e) {
           replyTo.send(new ChatServerStatus.error(e.toString()), null);
         }
       } else if (message.isStop) {
         replyTo.send(new ChatServerStatus.stopping(), null);
         stop();
         replyTo.send(new ChatServerStatus.stopped(), null);
@@ skipping 108 matching lines @@
     }
   }
 
   int _timeRange;
   List<int> _buckets;
   int _currentBucket;
   int _currentBucketTime;
   num _bucketTimeRange;
   int _sum;
 }