Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(336)

Side by Side Diff: sdk/lib/io/websocket_impl.dart

Issue 196423021: Move _StreamSinkImpl from dart:io to dart:async as StreamSinkAdapter. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 6 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« sdk/lib/io/io_sink.dart ('K') | « sdk/lib/io/io_sink.dart ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 846 matching lines...) Expand 10 before | Expand all | Expand 10 after
857 } 857 }
858 var protocol = response.headers.value('Sec-WebSocket-Protocol'); 858 var protocol = response.headers.value('Sec-WebSocket-Protocol');
859 return response.detachSocket() 859 return response.detachSocket()
860 .then((socket) => new _WebSocketImpl._fromSocket(socket, protocol)); 860 .then((socket) => new _WebSocketImpl._fromSocket(socket, protocol));
861 }); 861 });
862 } 862 }
863 863
864 _WebSocketImpl._fromSocket(this._socket, this.protocol, 864 _WebSocketImpl._fromSocket(this._socket, this.protocol,
865 [this._serverSide = false]) { 865 [this._serverSide = false]) {
866 _consumer = new _WebSocketConsumer(this, _socket); 866 _consumer = new _WebSocketConsumer(this, _socket);
867 _sink = new _StreamSinkImpl(_consumer); 867 _sink = new StreamSinkAdapter(_consumer);
868 _readyState = WebSocket.OPEN; 868 _readyState = WebSocket.OPEN;
869 869
870 var transformer = new _WebSocketProtocolTransformer(_serverSide); 870 var transformer = new _WebSocketProtocolTransformer(_serverSide);
871 _subscription = _socket.transform(transformer).listen( 871 _subscription = _socket.transform(transformer).listen(
872 (data) { 872 (data) {
873 if (data is _WebSocketPing) { 873 if (data is _WebSocketPing) {
874 if (!_writeClosed) _consumer.add(new _WebSocketPong(data.payload)); 874 if (!_writeClosed) _consumer.add(new _WebSocketPong(data.payload));
875 } else if (data is _WebSocketPong) { 875 } else if (data is _WebSocketPong) {
876 // Simply set pingInterval, as it'll cancel any timers. 876 // Simply set pingInterval, as it'll cancel any timers.
877 pingInterval = _pingInterval; 877 pingInterval = _pingInterval;
(...skipping 107 matching lines...) Expand 10 before | Expand all | Expand 10 after
985 (code < WebSocketStatus.NORMAL_CLOSURE || 985 (code < WebSocketStatus.NORMAL_CLOSURE ||
986 code == WebSocketStatus.RESERVED_1004 || 986 code == WebSocketStatus.RESERVED_1004 ||
987 code == WebSocketStatus.NO_STATUS_RECEIVED || 987 code == WebSocketStatus.NO_STATUS_RECEIVED ||
988 code == WebSocketStatus.ABNORMAL_CLOSURE || 988 code == WebSocketStatus.ABNORMAL_CLOSURE ||
989 (code > WebSocketStatus.INTERNAL_SERVER_ERROR && 989 (code > WebSocketStatus.INTERNAL_SERVER_ERROR &&
990 code < WebSocketStatus.RESERVED_1015) || 990 code < WebSocketStatus.RESERVED_1015) ||
991 (code >= WebSocketStatus.RESERVED_1015 && 991 (code >= WebSocketStatus.RESERVED_1015 &&
992 code < 3000)); 992 code < 3000));
993 } 993 }
994 } 994 }
OLDNEW
« sdk/lib/io/io_sink.dart ('K') | « sdk/lib/io/io_sink.dart ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698