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 {
