1-
21/// Tests for dart_node_ws library types and APIs.
32///
43/// These tests run in Node.js environment to get coverage for the library.
@@ -119,7 +118,7 @@ void main() {
119118 });
120119
121120 final client = _createWebSocketClient ('ws://localhost:$testPort ' );
122-
121+
123122 await completer.future.timeout (const Duration (seconds: 2 ));
124123 await _waitForOpen (client);
125124 client.close ();
@@ -139,8 +138,9 @@ void main() {
139138 await _waitForOpen (client);
140139 _sendMessage (client, 'Hello from client' );
141140
142- final receivedMessage = await messageCompleter.future
143- .timeout (const Duration (seconds: 2 ));
141+ final receivedMessage = await messageCompleter.future.timeout (
142+ const Duration (seconds: 2 ),
143+ );
144144 expect (receivedMessage, equals ('Hello from client' ));
145145 client.close ();
146146 });
@@ -159,8 +159,9 @@ void main() {
159159 messageCompleter.complete (message);
160160 });
161161
162- final receivedMessage = await messageCompleter.future
163- .timeout (const Duration (seconds: 2 ));
162+ final receivedMessage = await messageCompleter.future.timeout (
163+ const Duration (seconds: 2 ),
164+ );
164165 expect (receivedMessage, equals ('Welcome to server' ));
165166 client.close ();
166167 });
@@ -180,14 +181,19 @@ JSWebSocket _createWebSocketClient(String url) {
180181/// Waits for WebSocket to reach OPEN state
181182Future <void > _waitForOpen (JSWebSocket ws) async {
182183 final completer = Completer <void >();
183-
184+
184185 if (ws.readyState == 1 ) {
185186 completer.complete ();
186187 } else {
187188 ws.on ('open' , (() => completer.complete ()).toJS);
188- ws.on ('error' , ((JSAny error) => completer.completeError ('Connection failed: $error ' )).toJS);
189+ ws.on (
190+ 'error' ,
191+ ((JSAny error) => completer.completeError (
192+ 'Connection failed: $error ' ,
193+ )).toJS,
194+ );
189195 }
190-
196+
191197 return completer.future.timeout (const Duration (seconds: 2 ));
192198}
193199
0 commit comments