Make IOSink implement StringSink

samples/tests/samples/chat/chat_server_test.dart

-// Copyright (c) 2012, the Dart project authors.  Please see the AUTHORS file
+// Copyright (c) 2013, 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.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 
 import 'dart:io';
 import 'dart:isolate';
@@ skipping 47 matching lines @@
 
       // Test done.
       statusPort.send("Test succeeded", null);
     }
 
     Map leaveRequest = new Map();
     leaveRequest["request"] = "leave";
     leaveRequest["sessionId"] = sessionId;
     httpClient.post("127.0.0.1", port, "/leave")
       .then((HttpClientRequest request) {
-        request.addString(json.stringify(leaveRequest));
+        request.write(json.stringify(leaveRequest));
         return request.close();
       })
       .then((HttpClientResponse response) {
         StringBuffer body = new StringBuffer();
         response.listen(
-          (data) => body.add(new String.fromCharCodes(data)),
+          (data) => body.write(new String.fromCharCodes(data)),
           onDone: () => leaveResponseHandler(response, body.toString()));
       });
   }
 
   void receive() {
     void receiveResponseHandler(response, String data) {
       Expect.equals(HttpStatus.OK, response.statusCode);
       var responseData = json.parse(data);
       Expect.equals("receive", responseData["response"]);
       Expect.equals(null, responseData["disconnect"]);
@@ skipping 29 matching lines @@
         leave();
       }
     }
 
     Map receiveRequest = new Map();
     receiveRequest["request"] = "receive";
     receiveRequest["sessionId"] = sessionId;
     receiveRequest["nextMessage"] = receiveMessageNumber;
     httpClient.post("127.0.0.1", port, "/receive")
       .then((HttpClientRequest request) {
-        request.addString(json.stringify(receiveRequest));
+        request.write(json.stringify(receiveRequest));
         return request.close();
       })
       .then((HttpClientResponse response) {
         StringBuffer body = new StringBuffer();
         response.listen(
-          (data) => body.add(new String.fromCharCodes(data)),
+          (data) => body.write(new String.fromCharCodes(data)),
           onDone: () => receiveResponseHandler(response, body.toString()));
       });
   }
 
   void sendMessage() {
     void sendResponseHandler(response, String data) {
       Expect.equals(HttpStatus.OK, response.statusCode);
       var responseData = json.parse(data);
       Expect.equals("message", responseData["response"]);
       sendMessageNumber++;
       if (sendMessageNumber < messagesToSend) {
         sendMessage();
       } else {
         receive();
       }
     }
 
     Map messageRequest = new Map();
     messageRequest["request"] = "message";
     messageRequest["sessionId"] = sessionId;
     messageRequest["message"] = "message $sendMessageNumber";
     httpClient.post("127.0.0.1", port, "/message")
       .then((HttpClientRequest request) {
-        request.addString(json.stringify(messageRequest));
+        request.write(json.stringify(messageRequest));
         return request.close();
       })
       .then((HttpClientResponse response) {
         StringBuffer body = new StringBuffer();
         response.listen(
-          (data) => body.add(new String.fromCharCodes(data)),
+          (data) => body.write(new String.fromCharCodes(data)),
           onDone: () => sendResponseHandler(response, body.toString()));
       });
   }
 
   void join() {
     void joinResponseHandler(response, String data) {
       Expect.equals(HttpStatus.OK, response.statusCode);
       var responseData = json.parse(data);
       Expect.equals("join", responseData["response"]);
       sessionId = responseData["sessionId"];
       Expect.isTrue(sessionId != null);
 
       joinCount = 0;
       messageCount = 0;
       sendMessageNumber = 0;
       receiveMessageNumber = 0;
       sendMessage();
     }
 
     Map joinRequest = new Map();
     joinRequest["request"] = "join";
     joinRequest["handle"] = "test1";
     httpClient.post("127.0.0.1", port, "/join")
       .then((HttpClientRequest request) {
-        request.addString(json.stringify(joinRequest));
+        request.write(json.stringify(joinRequest));
         return request.close();
       })
       .then((HttpClientResponse response) {
         StringBuffer body = new StringBuffer();
         response.listen(
-          (data) => body.add(new String.fromCharCodes(data)),
+          (data) => body.write(new String.fromCharCodes(data)),
           onDone: () => joinResponseHandler(response, body.toString()));
       });
   }
 
   void dispatch(message, replyTo) {
     totalClients = message.totalClients;
     messagesToSend = message.messagesToSend;
     messagesToReceive = message.messagesToReceive;
     port = message.port;
     statusPort = replyTo;
@@ skipping 107 matching lines @@
   TestMain testMain = new TestMain.run(10, 2);
 }
 
 
 void main() {
   testOneClient();
   testTwoClients();
   testTwoClientsMoreMessages();
   testTenClients();
 }