anchor.diff:    void handleData(List<int> data, EventSink<List<int>> sink) {
       List<int> _temp = new List();
       Stream<List<int>> stream = new Stream.fromFuture(new Future.value(data));
  -    stream.transform(new ZLibDeflater()).listen((List<int> compressedData) {
  +    stream.transform(new ZLibEncoder()).listen((List<int> compressedData) {
         _temp.addAll(compressedData);
       }, onDone: () {
         _log("data size before/after Compress: ${data.length}/${_temp.length} bytes");
  
positive.code:     socket
      .transform(new _ByteListDecoder())
  //    .transform(new _Extract()) <- Very bad performance
      .transform(new StringDecoder())
      .transform(new _JsonLogger("incomming json"))
      .transform(new _JsonDecoder())
      .listen(_RequestHandler.notify);
  
negative.code:   void handleData(List<int> data, EventSink<List<int>> sink) {
      List<int> _temp = new List();
      Stream<List<int>> stream = new Stream.fromFuture(new Future.value(data));
      stream.transform(new ZLibDecoder()).listen((List<int> extractedData) {
        _temp.addAll(extractedData);
      }, onDone: () {
        _log("data size before/after Extract: ${data.length}/${_temp.length} bytes");
  