@Test
void readSimpleString() throws IOException {

    RedisInputStream stream = new RedisInputStream(new ByteArrayInputStream(Strings.bytes("line1\rline2\r\n")));
    String message = stream.readSimpleString();
    assertEquals("line1\rline2", message);
}