| Index: pkg/analysis_server/test/channel/web_socket_channel_test.dart
|
| diff --git a/pkg/analysis_server/test/channel/web_socket_channel_test.dart b/pkg/analysis_server/test/channel/web_socket_channel_test.dart
|
| index b7b6391fdcc0e54b8621e8d96a5d7c3e92479a71..8dcaca9953095b7cdc31bb9e2e5f174a023b4a5a 100644
|
| --- a/pkg/analysis_server/test/channel/web_socket_channel_test.dart
|
| +++ b/pkg/analysis_server/test/channel/web_socket_channel_test.dart
|
| @@ -12,8 +12,10 @@ import 'package:analyzer/instrumentation/instrumentation.dart';
|
| import 'package:unittest/unittest.dart';
|
|
|
| import '../mocks.dart';
|
| +import '../utils.dart';
|
|
|
| main() {
|
| + initializeTestEnvironment();
|
| group('WebSocketChannel', () {
|
| setUp(WebSocketChannelTest.setUp);
|
| test('close', WebSocketChannelTest.close);
|
| @@ -128,8 +130,9 @@ class WebSocketChannelTest {
|
|
|
| static Future response() {
|
| server.sendResponse(new Response('myId'));
|
| - return client.responseStream.first.timeout(new Duration(seconds: 1)).then(
|
| - (Response response) {
|
| + return client.responseStream.first
|
| + .timeout(new Duration(seconds: 1))
|
| + .then((Response response) {
|
| expect(response.id, equals('myId'));
|
| expectMsgCount(responseCount: 1);
|
| });
|
|
|