Make it possible to read a specific number of characters from a string input stream

runtime/bin/websocket_impl.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.
 
 const String _webSocketGUID = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
 
 class _WebSocketMessageType {
   static const int NONE = 0;
   static const int BINARY = 1;
   static const int TEXT = 2;
@@ skipping 275 matching lines @@
         String reason = "";
         if (_controlPayload.length > 0) {
           if (_controlPayload.length == 1) {
             throw new WebSocketException("Protocol error");
           }
           status = _controlPayload[0] << 8 | _controlPayload[1];
           if (_controlPayload.length > 2) {
             var decoder = _StringDecoders.decoder(Encoding.UTF_8);
             decoder.write(
                 _controlPayload.getRange(2, _controlPayload.length - 2));
-            reason = decoder.decoded;
+            reason = decoder.decoded();
           }
         }
         if (onClosed !== null) onClosed(status, reason);
         _state = CLOSED;
         break;
 
       case _WebSocketOpcode.PING:
         if (onPing !== null) onPing(_controlPayload);
         break;
 
@@ skipping 167 matching lines @@
     if (_currentMessageType == _WebSocketMessageType.TEXT) {
       _decoder.write(buffer.getRange(offset, count));
     } else {
       _outputStream.write(buffer.getRange(offset, count));
     }
   }
 
   _onWebSocketMessageEnd() {
     if (_onMessage !== null) {
       if (_currentMessageType == _WebSocketMessageType.TEXT) {
-        _onMessage(_decoder.decoded);
+        _onMessage(_decoder.decoded());
       } else {
         _onMessage(_outputStream.read());
       }
     }
     _decoder = null;
     _outputStream = null;
   }
 
   _onWebSocketPing(List<int> payload) {
     _sendFrame(_WebSocketOpcode.PONG, payload);
@@ skipping 356 matching lines @@
 
 class _WebSocketCloseEvent implements CloseEvent {
   _WebSocketCloseEvent(this._wasClean, this._code, this._reason);
   bool get wasClean => _wasClean;
   int get code => _code;
   String get reason => _reason;
   bool _wasClean;
   int _code;
   String _reason;
 }