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

Unified Diff: tests/standalone/io/web_socket_test.dart

Issue 14208007: Improve WebSocket interface by making it implement StreamSink. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years, 8 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « sdk/lib/io/websocket_impl.dart ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: tests/standalone/io/web_socket_test.dart
diff --git a/tests/standalone/io/web_socket_test.dart b/tests/standalone/io/web_socket_test.dart
index 9a126f45839697db2c3e201edaf784fd1974de5f..2bee0d8670eeb8731762b442adf4840db2b89c82 100644
--- a/tests/standalone/io/web_socket_test.dart
+++ b/tests/standalone/io/web_socket_test.dart
@@ -44,7 +44,7 @@ class SecurityConfiguration {
createServer().then((server) {
server.transform(new WebSocketTransformer()).listen((webSocket) {
webSocket.listen(
- webSocket.send,
+ webSocket.add,
onDone: () {
Expect.equals(closeStatus == null
? WebSocketStatus.NO_STATUS_RECEIVED
@@ -58,13 +58,13 @@ class SecurityConfiguration {
for (int i = 0; i < totalConnections; i++) {
int messageCount = 0;
createClient(server.port).then((webSocket) {
- webSocket.send(messageText);
+ webSocket.add(messageText);
webSocket.listen(
(message) {
messageCount++;
if (messageCount < 1 ) {
Expect.equals(messageText, message);
- webSocket.send(message);
+ webSocket.add(message);
} else {
webSocket.close(closeStatus, closeReason);
}
@@ -97,7 +97,7 @@ class SecurityConfiguration {
messageCount++;
if (messageCount < 10) {
Expect.equals(messageText, message);
- webSocket.send(message);
+ webSocket.add(message);
} else {
webSocket.close(closeStatus, closeReason);
}
@@ -112,13 +112,13 @@ class SecurityConfiguration {
server.close();
}
});
- webSocket.send(messageText);
+ webSocket.add(messageText);
});
for (int i = 0; i < totalConnections; i++) {
createClient(server.port).then((webSocket) {
webSocket.listen(
- webSocket.send,
+ webSocket.add,
onDone: () {
Expect.equals(closeStatus == null
? WebSocketStatus.NO_STATUS_RECEIVED
@@ -140,7 +140,7 @@ class SecurityConfiguration {
webSocket.listen(
(message) {
Expect.listEquals(originalMessage, message);
- webSocket.send(message);
+ webSocket.add(message);
});
});
@@ -151,7 +151,7 @@ class SecurityConfiguration {
webSocket.close();
},
onDone: server.close);
- webSocket.send(originalMessage);
+ webSocket.add(originalMessage);
});
});
}
@@ -273,7 +273,7 @@ class SecurityConfiguration {
messageCount++;
if (messageCount < 10) {
Expect.equals(messageText, message);
- webSocket.send(message);
+ webSocket.add(message);
} else {
webSocket.close(closeStatus, closeReason);
}
@@ -286,7 +286,7 @@ class SecurityConfiguration {
server.close();
}
});
- webSocket.send(messageText);
+ webSocket.add(messageText);
});
void webSocketConnection() {
@@ -306,7 +306,7 @@ class SecurityConfiguration {
Expect.isTrue(onopenCalled);
Expect.isFalse(oncloseCalled);
Expect.equals(WebSocket.OPEN, webSocket.readyState);
- webSocket.send(message);
+ webSocket.add(message);
},
onDone: () {
Expect.isTrue(onopenCalled);
@@ -332,7 +332,7 @@ class SecurityConfiguration {
if (WebSocketTransformer.isUpgradeRequest(request)) {
WebSocketTransformer.upgrade(request).then((webSocket) {
webSocket.listen((_) { webSocket.close(); });
- webSocket.send("Hello");
+ webSocket.add("Hello");
});
} else {
Expect.isFalse(WebSocketTransformer.isUpgradeRequest(request));
« no previous file with comments | « sdk/lib/io/websocket_impl.dart ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698