anchor.diff:  
           var rpt = new RedisProtocolTransformer();
   
  -        rpt.handleData("\$6\r\nfoobar\r\n\$8\r\nfoobars2\r\n".runes.toList(growable: false), sink);
  +        rpt.handleData(encodeUtf8("\$6\r\nfoobar\r\n\$8\r\nfoobars2\r\n"), sink);
   
           expect(sink.replies.length, equals(2));
           expect(sink.replies.first.runtimeType, equals(BulkReply));
  
positive.code: 
          var rpt = new RedisProtocolTransformer();
  
          rpt.handleData("\$6\r\nfoo".runes.toList(growable: false), sink);
  
          expect(sink.replies.length, equals(0));
  
          rpt.handleData("bar\r".runes.toList(growable: false), sink);
  
          expect(sink.replies.length, equals(0));
  
          rpt.handleData("\n\$4\r\ntest\r\n\$".runes.toList(growable: false), sink);
  
          expect(sink.replies.length, equals(2));
  
          rpt.handleData("3\r\nend\r\n\$1".runes.toList(growable: false), sink);
  
          expect(sink.replies.length, equals(3));
  
          rpt.handleData("1\r\nabcdefghijk\r\n".runes.toList(growable: false), sink);
  
          expect(sink.replies.length, equals(4));
  
  
negative.code: 
          var rpt = new RedisProtocolTransformer();
  
          rpt.handleData(encodeUtf8("+Status message\r\n:132\r\n-Error message\r\n"), sink);
          expect(sink.replies.length, equals(3));
          expect(sink.replies[0].runtimeType, equals(StatusReply));
          expect(sink.replies[1].runtimeType, equals(IntegerReply));
  