Fix Websocket compression tests for Client side.

sdk/lib/io/websocket_impl.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 part of dart.io;
 
 const String _webSocketGUID = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
 const String _clientNoContextTakeover = "client_no_context_takeover";
 const String _serverNoContextTakeover = "server_no_context_takeover";
 const String _clientMaxWindowBits = "client_max_window_bits";
@@ skipping 586 matching lines @@
     } else {
       buffer = msg;
     }
 
     encoder.process(buffer, 0, buffer.length);
 
     while ((out = encoder.processed()) != null) {
       result.addAll(out);
     }
 
+    if (!serverSide && clientNoContextTakeover) {
+      encoder.end();
+      encoder = null;

[Søren Gjesse, 2016/01/15 08:08:38]

Shouldn't there be similar logic in the other direction, or am I missing
something here?

From the way we create the headers it seems like we always honor both
client_no_context_takeover and server_no_context_takeover. I that case the
server side should also end its decoder when server_no_context_takeover is in
effect.

Likewise the decoder can also be "discarded" when no context takeover is on
effect.

Besides the Autobahn tests it would be great to have some local tests of the
different context take over combinations to ensure that the compression engines
are restarted/reused depending on these flags.

+    }
+
     if (result.length > 4) {
       result = result.sublist(0, result.length - 4);
     }
 
     return result;
   }
 }
 
 // TODO(ajohnsen): Make this transformer reusable.
 class _WebSocketOutgoingTransformer implements StreamTransformer, EventSink {
@@ skipping 612 matching lines @@
     return code != null &&
         (code < WebSocketStatus.NORMAL_CLOSURE ||
             code == WebSocketStatus.RESERVED_1004 ||
             code == WebSocketStatus.NO_STATUS_RECEIVED ||
             code == WebSocketStatus.ABNORMAL_CLOSURE ||
             (code > WebSocketStatus.INTERNAL_SERVER_ERROR &&
                 code < WebSocketStatus.RESERVED_1015) ||
             (code >= WebSocketStatus.RESERVED_1015 && code < 3000));
   }
 }