diff --git a/pkgs/web_socket_channel/lib/src/copy/web_socket_impl.dart b/pkgs/web_socket_channel/lib/src/copy/web_socket_impl.dart
index 260a341..e1c4d88 100644
--- a/pkgs/web_socket_channel/lib/src/copy/web_socket_impl.dart
+++ b/pkgs/web_socket_channel/lib/src/copy/web_socket_impl.dart
@@ -84,7 +84,6 @@
 
   int _state = START;
   bool _fin = false;
-  bool _compressed = false;
   int _opcode = -1;
   int _len = -1;
   bool _masked = false;
@@ -148,14 +147,6 @@
 
           _opcode = (byte & OPCODE);
 
-          if (_opcode != _WebSocketOpcode.CONTINUATION) {
-            if ((byte & RSV1) != 0) {
-              _compressed = true;
-            } else {
-              _compressed = false;
-            }
-          }
-
           if (_opcode <= _WebSocketOpcode.BINARY) {
             if (_opcode == _WebSocketOpcode.CONTINUATION) {
               if (_currentMessageType == _WebSocketMessageType.NONE) {
diff --git a/pkgs/web_socket_channel/pubspec.yaml b/pkgs/web_socket_channel/pubspec.yaml
index 0f04ff6..31d3a8f 100644
--- a/pkgs/web_socket_channel/pubspec.yaml
+++ b/pkgs/web_socket_channel/pubspec.yaml
@@ -1,5 +1,5 @@
 name: web_socket_channel
-version: 1.0.5
+version: 1.0.6-dev
 description: StreamChannel wrappers for WebSockets.
 author: Dart Team <misc@dartlang.org>
 homepage: https://github.com/dart-lang/web_socket_channel
diff --git a/pkgs/web_socket_channel/test/io_test.dart b/pkgs/web_socket_channel/test/io_test.dart
index a277d79..dfa718d 100644
--- a/pkgs/web_socket_channel/test/io_test.dart
+++ b/pkgs/web_socket_channel/test/io_test.dart
@@ -43,7 +43,7 @@
         fail("Only expected two messages.");
       }
       n++;
-    }, onDone: expectAsync(() {
+    }, onDone: expectAsync0(() {
       expect(channel.closeCode, equals(5678));
       expect(channel.closeReason, equals("raisin"));
     }));
@@ -64,11 +64,11 @@
     channel.sink.add("ping");
 
     channel.stream.listen(
-        expectAsync((message) {
+        expectAsync1((message) {
           expect(message, equals("pong"));
           channel.sink.close(5678, "raisin");
         }, count: 1),
-        onDone: expectAsync(() {}));
+        onDone: expectAsync0(() {}));
   });
 
   test(".connect with an immediate call to close", () async {