Fix analysis warnings
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 {