Add a web socket client

runtime/bin/http_parser.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.
 
 // Global constants.
 class _Const {
   // Bytes for "HTTP".
   static final HTTP = const [72, 84, 84, 80];
   // Bytes for "HTTP/1.".
   static final HTTP1DOT = const [72, 84, 84, 80, 47, 49, 46];
@@ skipping 401 matching lines @@
                 _headerField.addCharCode(_toLowerCase(byte));
                 _state = _State.HEADER_FIELD;
               }
             }
             break;
 
           case _State.HEADER_ENDING:
             _expect(byte, _CharCode.LF);
             if (_connectionUpgrade) {
               _state = _State.UPGRADED;
+              _unparsedData =
+                  buffer.getRange(index + 1, count - (index + 1 - offset));
               if (headersComplete != null) headersComplete();
             } else {
               if (headersComplete != null) headersComplete();
               if (_chunked) {
                 _state = _State.CHUNK_SIZE;
                 _remainingContent = 0;
               } else if (_contentLength == 0 ||
                          (_messageType == _MessageType.REQUEST &&
                           _contentLength == -1) ||
                          (_messageType == _MessageType.RESPONSE &&
@@ skipping 167 matching lines @@
 
   int get messageType() => _messageType;
   int get contentLength() => _contentLength;
   bool get upgrade() => _connectionUpgrade && _state == _State.UPGRADED;
   bool get persistentConnection() => _persistentConnection;
 
   void set responseToMethod(String method) => _responseToMethod = method;
 
   bool get isIdle() => _state == _State.START;
 
+  List<int> get unparsedData() => _unparsedData;
+
   void _bodyEnd() {
     if (dataEnd != null) {
       dataEnd(_messageType == _MessageType.RESPONSE && !_persistentConnection);
     }
   }
 
   _reset() {
     _state = _State.START;
     _messageType = _MessageType.UNDETERMINED;
     _headerField = new StringBuffer();
@@ skipping 69 matching lines @@
   int _httpVersion;
   int _contentLength;
   bool _persistentConnection;
   bool _connectionUpgrade;
   bool _chunked;
 
   bool _noMessageBody;
   String _responseToMethod;  // Indicates the method used for the request.
   int _remainingContent;
 
+  List<int> _unparsedData;  // Unparsed data after connection upgrade.
   // Callbacks.
   Function requestStart;
   Function responseStart;
   Function headerReceived;
   Function headersComplete;
   Function dataReceived;
   Function dataEnd;
   Function error;
 }
 
 
 class HttpParserException implements Exception {
   const HttpParserException([String this.message = ""]);
   String toString() => "HttpParserException: $message";
   final String message;
 }