OLD | NEW |
1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2014, 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 @TestOn('vm') | 5 @TestOn('vm') |
6 | 6 |
7 import 'dart:io'; | 7 import 'dart:io'; |
8 | 8 |
9 import 'package:stream_channel/stream_channel.dart'; | 9 import 'package:stream_channel/stream_channel.dart'; |
10 import 'package:test/test.dart'; | 10 import 'package:test/test.dart'; |
(...skipping 17 matching lines...) Expand all Loading... |
28 var request = await client.openUrl( | 28 var request = await client.openUrl( |
29 "GET", Uri.parse("http://localhost:${server.port}")); | 29 "GET", Uri.parse("http://localhost:${server.port}")); |
30 request.headers | 30 request.headers |
31 ..set("Connection", "Upgrade") | 31 ..set("Connection", "Upgrade") |
32 ..set("Upgrade", "websocket") | 32 ..set("Upgrade", "websocket") |
33 ..set("Sec-WebSocket-Key", "x3JJHMbDL1EzLkh9GBhXDw==") | 33 ..set("Sec-WebSocket-Key", "x3JJHMbDL1EzLkh9GBhXDw==") |
34 ..set("Sec-WebSocket-Version", "13"); | 34 ..set("Sec-WebSocket-Version", "13"); |
35 | 35 |
36 var response = await request.close(); | 36 var response = await request.close(); |
37 var socket = await response.detachSocket(); | 37 var socket = await response.detachSocket(); |
38 var innerChannel = new StreamChannel(socket, socket); | 38 var innerChannel = new StreamChannel<List<int>>(socket, socket); |
39 var webSocket = new WebSocketChannel(innerChannel, serverSide: false); | 39 var webSocket = new WebSocketChannel(innerChannel, serverSide: false); |
40 | 40 |
41 var n = 0; | 41 var n = 0; |
42 await webSocket.stream.listen((message) { | 42 await webSocket.stream.listen((message) { |
43 if (n == 0) { | 43 if (n == 0) { |
44 expect(message, equals("hello!")); | 44 expect(message, equals("hello!")); |
45 webSocket.sink.add("ping"); | 45 webSocket.sink.add("ping"); |
46 } else if (n == 1) { | 46 } else if (n == 1) { |
47 expect(message, equals("pong")); | 47 expect(message, equals("pong")); |
48 webSocket.sink.close(); | 48 webSocket.sink.close(); |
(...skipping 11 matching lines...) Expand all Loading... |
60 var response = request.response; | 60 var response = request.response; |
61 response.statusCode = 101; | 61 response.statusCode = 101; |
62 response.headers | 62 response.headers |
63 ..set("Connection", "Upgrade") | 63 ..set("Connection", "Upgrade") |
64 ..set("Upgrade", "websocket") | 64 ..set("Upgrade", "websocket") |
65 ..set("Sec-WebSocket-Accept", WebSocketChannel | 65 ..set("Sec-WebSocket-Accept", WebSocketChannel |
66 .signKey(request.headers.value('Sec-WebSocket-Key'))); | 66 .signKey(request.headers.value('Sec-WebSocket-Key'))); |
67 response.contentLength = 0; | 67 response.contentLength = 0; |
68 | 68 |
69 var socket = await response.detachSocket(); | 69 var socket = await response.detachSocket(); |
70 var innerChannel = new StreamChannel(socket, socket); | 70 var innerChannel = new StreamChannel<List<int>>(socket, socket); |
71 var webSocket = new WebSocketChannel(innerChannel); | 71 var webSocket = new WebSocketChannel(innerChannel); |
72 webSocket.sink.add("hello!"); | 72 webSocket.sink.add("hello!"); |
73 | 73 |
74 var message = await webSocket.stream.first; | 74 var message = await webSocket.stream.first; |
75 expect(message, equals("ping")); | 75 expect(message, equals("ping")); |
76 webSocket.sink.add("pong"); | 76 webSocket.sink.add("pong"); |
77 webSocket.sink.close(); | 77 webSocket.sink.close(); |
78 }); | 78 }); |
79 | 79 |
80 var webSocket = await WebSocket.connect('ws://localhost:${server.port}'); | 80 var webSocket = await WebSocket.connect('ws://localhost:${server.port}'); |
81 var n = 0; | 81 var n = 0; |
82 await webSocket.listen((message) { | 82 await webSocket.listen((message) { |
83 if (n == 0) { | 83 if (n == 0) { |
84 expect(message, equals("hello!")); | 84 expect(message, equals("hello!")); |
85 webSocket.add("ping"); | 85 webSocket.add("ping"); |
86 } else if (n == 1) { | 86 } else if (n == 1) { |
87 expect(message, equals("pong")); | 87 expect(message, equals("pong")); |
88 webSocket.close(); | 88 webSocket.close(); |
89 server.close(); | 89 server.close(); |
90 } else { | 90 } else { |
91 fail("Only expected two messages."); | 91 fail("Only expected two messages."); |
92 } | 92 } |
93 n++; | 93 n++; |
94 }).asFuture(); | 94 }).asFuture(); |
95 }); | 95 }); |
96 }); | 96 }); |
97 } | 97 } |
OLD | NEW |