| 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 |