Update the streams interfaces

tests/standalone/src/EchoServerStreamTest.dart

 // Copyright (c) 2011, 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.
 //
 // Echo server test program to test socket streams.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
@@ skipping 36 matching lines @@
     void errorHandler() {
       print("Socket error");
       _socket.close();
     }
 
     void connectHandler() {
 
       SocketOutputStream stream = _socket.outputStream;
 
       void dataSent() {
-        // Reset buffer
-        for (int i = 0; i < MSGSIZE; i++) {
-          _buffer[i] = 1;
-        }
-        SocketInputStream stream = _socket.inputStream;
+        InputStream inputStream = _socket.inputStream;
+        int offset = 0;
+        List<int> data;
 
         void dataReceived() {
-          for (int i = 0; i < MSGSIZE; i++) {
-            Expect.equals(FIRSTCHAR + i, _buffer[i]);
+          // Test both read and readInto.
+          int bytesRead = 0;
+          if (_messages % 2 == 0) {
+            bytesRead = inputStream.readInto(data, offset, MSGSIZE - offset);
+            for (int i = 0; i < offset + bytesRead; i++) {
+              Expect.equals(FIRSTCHAR + i, data[i]);
+            }
+          } else {
+            data = inputStream.read();
+            bytesRead = data.length;
+            for (int i = 0; i < data.length; i++) {
+              Expect.equals(FIRSTCHAR + i + offset, data[i]);
+            }
           }
-          _messages++;
-          _socket.close();
-          if (_messages < MESSAGES) {
-            sendData();
-          } else {
-            shutdown();
+
+          offset += bytesRead;
+          if (offset == MSGSIZE) {
+            _messages++;
+            _socket.close();
+            if (_messages < MESSAGES) {
+              sendData();
+            } else {
+              shutdown();
+            }
           }
         }
 
-        bool read = stream.read(_buffer, 0, MSGSIZE, dataReceived);
-        if (read) {
-          dataReceived();
-        }
+        if (_messages % 2 == 0) data = new List<int>(MSGSIZE);
+        inputStream.dataHandler = dataReceived;
       }
 
       _socket.setCloseHandler(closeHandler);
       _socket.setErrorHandler(errorHandler);
       bool written = stream.write(_buffer, 0, MSGSIZE, dataSent);
       if (written) {
         dataSent();
       }
     }
 
@@ skipping 28 matching lines @@
 
 class EchoServer extends Isolate {
 
   static final HOST = "127.0.0.1";
   static final int MSGSIZE = EchoServerGame.MSGSIZE;
 
   void main() {
 
     void connectionHandler() {
       Socket _client;
+      InputStream inputStream;
+      List<int> buffer = new List<int>(MSGSIZE);
+      int offset = 0;
 
-      void messageHandler() {
-
-        List<int> buffer = new List<int>(MSGSIZE);
-
-        void dataReceived() {
-
-          SocketOutputStream outputStream = _client.outputStream;
-
-          for (int i = 0; i < MSGSIZE; i++) {
+      void dataReceived() {
+        SocketOutputStream outputStream = _client.outputStream;
+        int bytesRead = inputStream.readInto(buffer, offset, MSGSIZE - offset);
+        if (bytesRead > 0) {
+          offset += bytesRead;
+          for (int i = 0; i < offset; i++) {
             Expect.equals(EchoServerGame.FIRSTCHAR + i, buffer[i]);
           }
-          outputStream.write(buffer, 0, MSGSIZE, null);
-        }
-
-        SocketInputStream inputStream = _client.inputStream;
-        bool read = inputStream.read(buffer, 0, MSGSIZE, dataReceived);
-        if (read) {
-          dataReceived();
+          if (offset == MSGSIZE) {
+            outputStream.write(buffer, 0, buffer.length, null);
+          }
         }
       }
 
       void closeHandler() {
         _client.close();
       }
 
       void errorHandler() {
         print("Socket error");
         _client.close();
       }
 
       _client = _server.accept();
-      _client.setDataHandler(messageHandler);
+      inputStream = _client.inputStream;
+      inputStream.dataHandler = dataReceived;
       _client.setCloseHandler(closeHandler);
       _client.setErrorHandler(errorHandler);
     }
 
     void errorHandlerServer() {
       print("Server socket error");
       _server.close();
     }
 
     this.port.receive((message, SendPort replyTo) {
       if (message == EchoServerGame.SERVERINIT) {
         _server = new ServerSocket(HOST, 0, 10);
         Expect.equals(true, _server !== null);
         _server.setConnectionHandler(connectionHandler);
         _server.setErrorHandler(errorHandlerServer);
         replyTo.send(_server.port, null);
       } else if (message == EchoServerGame.SERVERSHUTDOWN) {
         _server.close();
         this.port.close();
       }
     });
   }
 
   ServerSocket _server;
 }
 
 main() {
   EchoServerStreamTest.testMain();
 }