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

Side by Side Diff: test/web_socket_test.dart

Issue 1959433002: Fix all strong-mode errors and warnings. (Closed) Base URL: git@github.com:dart-lang/web_socket_channel.git@master
Patch Set: Created 4 years, 7 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 unified diff | Download patch
« no previous file with comments | « test/html_test.dart ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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 }
OLDNEW
« no previous file with comments | « test/html_test.dart ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698