Index: sdk/lib/io/websocket_impl.dart |
diff --git a/sdk/lib/io/websocket_impl.dart b/sdk/lib/io/websocket_impl.dart |
index 047cf697ea135feda1b815d4f03e09b2bbe4a04b..aa2a1e52d3eb0b5deeeaaabcfa66b8718a270537 100644 |
--- a/sdk/lib/io/websocket_impl.dart |
+++ b/sdk/lib/io/websocket_impl.dart |
@@ -453,7 +453,7 @@ class _WebSocketTransformerImpl implements WebSocketTransformer { |
var deflate = _negotiateCompression(request, response, compression); |
response.headers.contentLength = 0; |
- return response.detachSocket().then/*<WebSocket>*/((socket) => |
+ return response.detachSocket().then<WebSocket>((socket) => |
new _WebSocketImpl._fromSocket( |
socket, protocol, compression, true, deflate)); |
} |
@@ -465,7 +465,7 @@ class _WebSocketTransformerImpl implements WebSocketTransformer { |
// the lists with ', ' and then tokenize. |
protocols = _HttpParser._tokenizeFieldValue(protocols.join(', ')); |
return new Future<String>(() => _protocolSelector(protocols)) |
- .then/*<String>*/((protocol) { |
+ .then<String>((protocol) { |
if (protocols.indexOf(protocol) < 0) { |
throw new WebSocketException( |
"Selected protocol is not in the list of available protocols"); |
@@ -476,7 +476,7 @@ class _WebSocketTransformerImpl implements WebSocketTransformer { |
..statusCode = HttpStatus.INTERNAL_SERVER_ERROR |
..close(); |
throw error; |
- }).then/*<WebSocket>*/(upgrade); |
+ }).then<WebSocket>(upgrade); |
} else { |
return upgrade(null); |
} |
@@ -1051,7 +1051,7 @@ class _WebSocketImpl extends Stream with _ServiceObject implements WebSocket { |
_WebSocketPerMessageDeflate deflate = |
negotiateClientCompression(response, compression); |
- return response.detachSocket().then/*<WebSocket>*/((socket) => |
+ return response.detachSocket().then<WebSocket>((socket) => |
new _WebSocketImpl._fromSocket( |
socket, protocol, compression, false, deflate)); |
}); |