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

Unified Diff: test/web_socket_test.dart

Issue 1950183003: Remove deprecated APIs. (Closed) Base URL: git@github.com:dart-lang/http_parser@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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « pubspec.yaml ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: test/web_socket_test.dart
diff --git a/test/web_socket_test.dart b/test/web_socket_test.dart
deleted file mode 100644
index 53aa5be41563542ef04aefd21c0c9c52a503ce52..0000000000000000000000000000000000000000
--- a/test/web_socket_test.dart
+++ /dev/null
@@ -1,183 +0,0 @@
-// Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file
-// for details. All rights reserved. Use of this source code is governed by a
-// BSD-style license that can be found in the LICENSE file.
-
-@TestOn('vm')
-
-import 'dart:io';
-
-import 'package:http_parser/http_parser.dart';
-import 'package:stream_channel/stream_channel.dart';
-import 'package:test/test.dart';
-
-void main() {
- group("using WebSocketChannel", () {
- test("a client can communicate with a WebSocket server", () async {
- var server = await HttpServer.bind("localhost", 0);
- server.transform(new WebSocketTransformer()).listen((webSocket) {
- webSocket.add("hello!");
- webSocket.listen((request) {
- expect(request, equals("ping"));
- webSocket.add("pong");
- webSocket.close();
- });
- });
-
- var client = new HttpClient();
- var request = await client.openUrl(
- "GET", Uri.parse("http://localhost:${server.port}"));
- request.headers
- ..set("Connection", "Upgrade")
- ..set("Upgrade", "websocket")
- ..set("Sec-WebSocket-Key", "x3JJHMbDL1EzLkh9GBhXDw==")
- ..set("Sec-WebSocket-Version", "13");
-
- var response = await request.close();
- var socket = await response.detachSocket();
- var innerChannel = new StreamChannel(socket, socket);
- var webSocket = new WebSocketChannel(innerChannel, serverSide: false);
-
- var n = 0;
- await webSocket.stream.listen((message) {
- if (n == 0) {
- expect(message, equals("hello!"));
- webSocket.sink.add("ping");
- } else if (n == 1) {
- expect(message, equals("pong"));
- webSocket.sink.close();
- server.close();
- } else {
- fail("Only expected two messages.");
- }
- n++;
- }).asFuture();
- });
-
- test("a server can communicate with a WebSocket client", () async {
- var server = await HttpServer.bind("localhost", 0);
- server.listen((request) async {
- var response = request.response;
- response.statusCode = 101;
- response.headers
- ..set("Connection", "Upgrade")
- ..set("Upgrade", "websocket")
- ..set("Sec-WebSocket-Accept", CompatibleWebSocket
- .signKey(request.headers.value('Sec-WebSocket-Key')));
- response.contentLength = 0;
-
- var socket = await response.detachSocket();
- var innerChannel = new StreamChannel(socket, socket);
- var webSocket = new WebSocketChannel(innerChannel);
- webSocket.sink.add("hello!");
-
- var message = await webSocket.stream.first;
- expect(message, equals("ping"));
- webSocket.sink.add("pong");
- webSocket.sink.close();
- });
-
- var webSocket = await WebSocket.connect('ws://localhost:${server.port}');
- var n = 0;
- await webSocket.listen((message) {
- if (n == 0) {
- expect(message, equals("hello!"));
- webSocket.add("ping");
- } else if (n == 1) {
- expect(message, equals("pong"));
- webSocket.close();
- server.close();
- } else {
- fail("Only expected two messages.");
- }
- n++;
- }).asFuture();
- });
- });
-
- group("using CompatibleWebSocket", () {
- test("a client can communicate with a WebSocket server", () {
- return HttpServer.bind("localhost", 0).then((server) {
- server.transform(new WebSocketTransformer()).listen((webSocket) {
- webSocket.add("hello!");
- webSocket.listen((request) {
- expect(request, equals("ping"));
- webSocket.add("pong");
- webSocket.close();
- });
- });
-
- var client = new HttpClient();
- return client
- .openUrl("GET", Uri.parse("http://localhost:${server.port}"))
- .then((request) {
- request.headers
- ..set("Connection", "Upgrade")
- ..set("Upgrade", "websocket")
- ..set("Sec-WebSocket-Key", "x3JJHMbDL1EzLkh9GBhXDw==")
- ..set("Sec-WebSocket-Version", "13");
- return request.close();
- }).then((response) => response.detachSocket()).then((socket) {
- var webSocket = new CompatibleWebSocket(socket, serverSide: false);
-
- var n = 0;
- return webSocket.listen((message) {
- if (n == 0) {
- expect(message, equals("hello!"));
- webSocket.add("ping");
- } else if (n == 1) {
- expect(message, equals("pong"));
- webSocket.close();
- server.close();
- } else {
- fail("Only expected two messages.");
- }
- n++;
- }).asFuture();
- });
- });
- });
-
- test("a server can communicate with a WebSocket client", () {
- return HttpServer.bind("localhost", 0).then((server) {
- server.listen((request) {
- var response = request.response;
- response.statusCode = 101;
- response.headers
- ..set("Connection", "Upgrade")
- ..set("Upgrade", "websocket")
- ..set("Sec-WebSocket-Accept", CompatibleWebSocket
- .signKey(request.headers.value('Sec-WebSocket-Key')));
- response.contentLength = 0;
- response.detachSocket().then((socket) {
- var webSocket = new CompatibleWebSocket(socket);
- webSocket.add("hello!");
- webSocket.first.then((request) {
- expect(request, equals("ping"));
- webSocket.add("pong");
- webSocket.close();
- });
- });
- });
-
- return WebSocket
- .connect('ws://localhost:${server.port}')
- .then((webSocket) {
- var n = 0;
- return webSocket.listen((message) {
- if (n == 0) {
- expect(message, equals("hello!"));
- webSocket.add("ping");
- } else if (n == 1) {
- expect(message, equals("pong"));
- webSocket.close();
- server.close();
- } else {
- fail("Only expected two messages.");
- }
- n++;
- }).asFuture();
- });
- });
- });
- });
-}
« no previous file with comments | « pubspec.yaml ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698