diff --git a/test/io_test.dart b/test/io_test.dart
index 1b7ae35..2d5d578 100644
--- a/test/io_test.dart
+++ b/test/io_test.dart
@@ -67,12 +67,10 @@ void main() {
 
     channel.sink.add('ping');
 
-    channel.stream.listen(
-        expectAsync1((message) {
-          expect(message, equals('pong'));
-          channel.sink.close(3678, 'raisin');
-        }, count: 1),
-        onDone: expectAsync0(() {}));
+    channel.stream.listen(expectAsync1((message) {
+      expect(message, equals('pong'));
+      channel.sink.close(3678, 'raisin');
+    }), onDone: expectAsync0(() {}));
   });
 
   test('.connect communicates immediately using platform independent api',
@@ -94,12 +92,10 @@ void main() {
 
     channel.sink.add('ping');
 
-    channel.stream.listen(
-        expectAsync1((message) {
-          expect(message, equals('pong'));
-          channel.sink.close(3678, 'raisin');
-        }, count: 1),
-        onDone: expectAsync0(() {}));
+    channel.stream.listen(expectAsync1((message) {
+      expect(message, equals('pong'));
+      channel.sink.close(3678, 'raisin');
+    }), onDone: expectAsync0(() {}));
   });
 
   test('.connect with an immediate call to close', () async {