| 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 b655b13e1598b4391d467c15f0ced8ac79241c2e..2aa9fb953eb5681414bd91c6d8db941d31ceedf4 100644
|
| --- a/tests/standalone/io/web_socket_protocol_processor_test.dart
|
| +++ b/tests/standalone/io/web_socket_protocol_processor_test.dart
|
| @@ -101,7 +101,7 @@ void testFullMessages() {
|
| int messageCount = 0;
|
| // Use the same web socket protocol transformer for all frames.
|
| var transformer = new _WebSocketProtocolTransformer();
|
| - var controller = new StreamController();
|
| + var controller = new StreamController(sync: true);
|
| WebSocketMessageCollector mc = new WebSocketMessageCollector(
|
| controller.stream.transform(transformer),
|
| message);
|
| @@ -165,7 +165,7 @@ void testFullMessages() {
|
| void testFragmentedMessages() {
|
| // Use the same web socket protocol transformer for all frames.
|
| var transformer = new _WebSocketProtocolTransformer();
|
| - var controller = new StreamController();
|
| + var controller = new StreamController(sync: true);
|
| WebSocketMessageCollector mc = new WebSocketMessageCollector(
|
| controller.stream.transform(transformer));
|
|
|
| @@ -230,7 +230,7 @@ void testFragmentedMessages() {
|
|
|
| void testUnmaskedMessage() {
|
| var transformer = new _WebSocketProtocolTransformer(true);
|
| - var controller = new StreamController();
|
| + var controller = new StreamController(sync: true);
|
| var port = new ReceivePort();
|
| controller.stream.transform(transformer).listen((_) {}, onError: (e) {
|
| port.close();
|
|
|