anchor.diff:  
           var rpt = new RedisProtocolTransformer();
   
  -        rpt.handleData("+Status m".runes.toList(growable: false), sink);
  -        expect(sink.replies.length, equals(0));
  -
  -        rpt.handleData("essage\r".runes.toList(growable: false), sink);
  +        rpt.handleData(encodeUtf8("+Status m"), sink);
  +        expect(sink.replies.length, equals(0));
  +
  +        rpt.handleData(encodeUtf8("essage\r"), sink);
           // Shouldn't be handled yet because of the missing \n
           expect(sink.replies.length, equals(0));
   
  -        rpt.handleData("\n:1234\r\n-Start of err".runes.toList(growable: false), sink);
  +        rpt.handleData(encodeUtf8("\n:1234\r\n-Start of err"), sink);
   
           // Should have handled the status and the integer
           expect(sink.replies.length, equals(2));
   
  -        rpt.handleData("or end\r\n".runes.toList(growable: false), sink);
  +        rpt.handleData(encodeUtf8("or end\r\n"), sink);
   
           expect(sink.replies.length, equals(3));
   
  
positive.code: 
          var rpt = new RedisProtocolTransformer();
  
          rpt.handleData("+Status message\r\n:132\r\n-Error message\r\n".runes.toList(growable: false), sink);
          expect(sink.replies.length, equals(3));
          expect(sink.replies[0].runtimeType, equals(StatusReply));
          expect(sink.replies[1].runtimeType, equals(IntegerReply));
  
negative.code: 
          var rpt = new RedisProtocolTransformer();
  
          rpt.handleData(encodeUtf8("+Status message\r\n"), sink);
          expect(sink.replies.length, equals(1));
          expect(sink.replies.last.runtimeType, equals(StatusReply));
          StatusReply tested1 = sink.replies.last;
          expect(tested1.status, equals("Status message"));
  
          rpt.handleData(encodeUtf8("-Error message\r\n"), sink);
          expect(sink.replies.length, equals(2));
          expect(sink.replies.last.runtimeType, equals(ErrorReply));
          ErrorReply tested2 = sink.replies.last;
          expect(tested2.error, equals("Error message"));
  
          rpt.handleData(encodeUtf8(":12345\r\n"), sink);
          expect(sink.replies.length, equals(3));
          expect(sink.replies.last.runtimeType, equals(IntegerReply));
          IntegerReply tested3 = sink.replies.last;
  