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

Side by Side Diff: tests/standalone/io/web_socket_protocol_test.dart

Issue 91223002: Add support for Websocket protocols. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years 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
OLDNEW
(Empty)
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
3 // BSD-style license that can be found in the LICENSE file.
4 //
5 // VMOptions=
6 // VMOptions=--short_socket_read
7 // VMOptions=--short_socket_write
8 // VMOptions=--short_socket_read --short_socket_write
9
10 import "package:expect/expect.dart";
11 import "dart:async";
12 import "dart:io";
13
14
15 testEmptyProtocol() {
16 HttpServer.bind("127.0.0.1", 0).then((server) {
17 server.listen((request) {
18 WebSocketTransformer.upgrade(request).then((websocket) {
19 websocket.close();
20 });
21 });
22 WebSocket.connect("ws://127.0.0.1:${server.port}/",
23 protocols: []).then((client) {
24 Expect.isNull(client.protocol);
25 client.close();
26 server.close();
27 });
28 });
29 }
30
31
32 testProtocol(List<String> protocols, String used) {
33 selector(List<String> receivedProtocols) {
34 Expect.listEquals(protocols, receivedProtocols);
35 return used;
36 }
37 HttpServer.bind("127.0.0.1", 0).then((server) {
38 server.listen((request) {
39 WebSocketTransformer.upgrade(request,
40 protocolSelector: selector)
41 .then((websocket) {
42 Expect.equals(used, websocket.protocol);
43 websocket.close();
44 });
45 });
46 WebSocket.connect("ws://127.0.0.1:${server.port}/",
47 protocols: protocols).then((client) {
48 Expect.equals(used, client.protocol);
49 client.close();
50 server.close();
51 });
52 });
53 }
54
55
56 testProtocolHandler() {
57 selector(List<String> receivedProtocols) {
58 throw "error";
59 }
60 HttpServer.bind("127.0.0.1", 0).then((server) {
61 server.listen((request) {
62 WebSocketTransformer.upgrade(request,
63 protocolSelector: selector)
64 .then((websocket) {
65 Expect.fail('error expected');
66 }, onError: (error) {
67 Expect.equals('error', error);
68 });
69 });
70 WebSocket.connect("ws://127.0.0.1:${server.port}/",
71 protocols: ["v1.example.com"])
72 .then((client) {
73 Expect.fail('error expected');
74 }, onError: (error) {
75 server.close();
76 });
77 });
78 }
79
80
81 void main() {
82 testEmptyProtocol();
83 testProtocol(["v1.example.com", "v2.example.com"], "v1.example.com");
84 testProtocol(["v1.example.com", "v2.example.com"], "v2.example.com");
85 testProtocolHandler();
86 }
87
OLDNEW
« sdk/lib/io/websocket_impl.dart ('K') | « tests/standalone/io/socket_test.dart ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698