commit 24382b6c90d94862bd2ffdc04882d3a062558839
author Nate Bosch <nbosch@google.com> Thu Aug 08 13:36:42 2019 -0700
committer GitHub <noreply@github.com> Thu Aug 08 13:36:42 2019 -0700
tree a3a66e032c12a647046fb2ee5b513e9ade1a6a14
parent 82692f969d7213a572d634d79946b97fe6a6ce57

Use `drain` to reach end of stream in tests (#75)

Replace `.toList()` for cases where we don't care about the collected
values.

Replace `.listen(null).asFuture()` since that is exactly the
implementation of `drain`.

test/io_test.dart

diff --git a/test/io_test.dart b/test/io_test.dart
index ada0608..f9032cd 100644
--- a/test/io_test.dart
+++ b/test/io_test.dart
@@ -75,7 +75,7 @@
     server.transform(WebSocketTransformer()).listen((webSocket) {
       expect(() async {
         var channel = IOWebSocketChannel(webSocket);
-        await channel.stream.listen(null).asFuture();
+        await channel.stream.drain();
         expect(channel.closeCode, equals(5678));
         expect(channel.closeReason, equals("raisin"));
       }(), completes);
@@ -94,7 +94,7 @@
     });
 
     var channel = IOWebSocketChannel.connect("ws://localhost:${server.port}");
-    expect(channel.stream.toList(),
+    expect(channel.stream.drain(),
         throwsA(TypeMatcher<WebSocketChannelException>()));
   });
 
@@ -111,7 +111,7 @@
 
     var channel = IOWebSocketChannel.connect("ws://localhost:${server.port}",
         protocols: [failedProtocol]);
-    expect(channel.stream.toList(),
+    expect(channel.stream.drain(),
         throwsA(TypeMatcher<WebSocketChannelException>()));
   });
 
@@ -129,7 +129,7 @@
 
     var channel = IOWebSocketChannel.connect("ws://localhost:${server.port}",
         protocols: [passedProtocol]);
-    await channel.stream.listen(null).asFuture();
+    await channel.stream.drain();
     expect(channel.protocol, passedProtocol);
   });
 }