| Index: tests/standalone/io/web_socket_protocol_processor_test.dart
|
| diff --git a/tests/standalone/io/web_socket_protocol_processor_test.dart b/tests/standalone/io/web_socket_protocol_processor_test.dart
|
| index 4354ab0d27d03f49fcb25d34d0da2f3096aa7123..17f57f9945df73ee8214e3bd294c4c0e316d4974 100644
|
| --- a/tests/standalone/io/web_socket_protocol_processor_test.dart
|
| +++ b/tests/standalone/io/web_socket_protocol_processor_test.dart
|
| @@ -2,7 +2,6 @@
|
| // 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.
|
|
|
| -import "package:expect/expect.dart";
|
| import "dart:convert";
|
| import "dart:math";
|
| import "dart:async";
|
| @@ -10,6 +9,9 @@ import "dart:collection";
|
| import "dart:typed_data";
|
| import "dart:isolate";
|
|
|
| +import "package:async_helper/async_helper.dart";
|
| +import "package:expect/expect.dart";
|
| +
|
| part '../../../sdk/lib/io/common.dart';
|
| part "../../../sdk/lib/io/http.dart";
|
| part "../../../sdk/lib/io/bytes_builder.dart";
|
| @@ -232,9 +234,9 @@ void testFragmentedMessages() {
|
| void testUnmaskedMessage() {
|
| var transformer = new _WebSocketProtocolTransformer(true);
|
| var controller = new StreamController(sync: true);
|
| - var port = new ReceivePort();
|
| + asyncStart();
|
| controller.stream.transform(transformer).listen((_) {}, onError: (e) {
|
| - port.close();
|
| + asyncEnd();
|
| });
|
| var message = new Uint8List(10);
|
| List<int> frame = createFrame(
|
|
|