| OLD | NEW |
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 part of dart.io; | 5 part of dart.io; |
| 6 | 6 |
| 7 const String _webSocketGUID = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"; | 7 const String _webSocketGUID = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"; |
| 8 | 8 |
| 9 // Matches _WebSocketOpcode. | 9 // Matches _WebSocketOpcode. |
| 10 class _WebSocketMessageType { | 10 class _WebSocketMessageType { |
| (...skipping 733 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 744 class _WebSocketImpl extends Stream with _ServiceObject implements WebSocket { | 744 class _WebSocketImpl extends Stream with _ServiceObject implements WebSocket { |
| 745 // Use default Map so we keep order. | 745 // Use default Map so we keep order. |
| 746 static Map<int, _WebSocketImpl> _webSockets = new Map<int, _WebSocketImpl>(); | 746 static Map<int, _WebSocketImpl> _webSockets = new Map<int, _WebSocketImpl>(); |
| 747 | 747 |
| 748 final String protocol; | 748 final String protocol; |
| 749 | 749 |
| 750 StreamController _controller; | 750 StreamController _controller; |
| 751 StreamSubscription _subscription; | 751 StreamSubscription _subscription; |
| 752 StreamSink _sink; | 752 StreamSink _sink; |
| 753 | 753 |
| 754 final Socket _socket; | 754 final _socket; |
| 755 final bool _serverSide; | 755 final bool _serverSide; |
| 756 int _readyState = WebSocket.CONNECTING; | 756 int _readyState = WebSocket.CONNECTING; |
| 757 bool _writeClosed = false; | 757 bool _writeClosed = false; |
| 758 int _closeCode; | 758 int _closeCode; |
| 759 String _closeReason; | 759 String _closeReason; |
| 760 Duration _pingInterval; | 760 Duration _pingInterval; |
| 761 Timer _pingTimer; | 761 Timer _pingTimer; |
| 762 _WebSocketConsumer _consumer; | 762 _WebSocketConsumer _consumer; |
| 763 | 763 |
| 764 int _outCloseCode; | 764 int _outCloseCode; |
| (...skipping 240 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1005 (code < WebSocketStatus.NORMAL_CLOSURE || | 1005 (code < WebSocketStatus.NORMAL_CLOSURE || |
| 1006 code == WebSocketStatus.RESERVED_1004 || | 1006 code == WebSocketStatus.RESERVED_1004 || |
| 1007 code == WebSocketStatus.NO_STATUS_RECEIVED || | 1007 code == WebSocketStatus.NO_STATUS_RECEIVED || |
| 1008 code == WebSocketStatus.ABNORMAL_CLOSURE || | 1008 code == WebSocketStatus.ABNORMAL_CLOSURE || |
| 1009 (code > WebSocketStatus.INTERNAL_SERVER_ERROR && | 1009 (code > WebSocketStatus.INTERNAL_SERVER_ERROR && |
| 1010 code < WebSocketStatus.RESERVED_1015) || | 1010 code < WebSocketStatus.RESERVED_1015) || |
| 1011 (code >= WebSocketStatus.RESERVED_1015 && | 1011 (code >= WebSocketStatus.RESERVED_1015 && |
| 1012 code < 3000)); | 1012 code < 3000)); |
| 1013 } | 1013 } |
| 1014 } | 1014 } |
| OLD | NEW |