@Test
void process() throws Exception {

    var connection = new RedisConnection();
    connection.outputStream = new RedisOutputStream(new ByteArrayOutputStream(), 512);
    connection.inputStream = new RedisInputStream(new ByteArrayInputStream(Strings.bytes("*3\r\n$9\r\nsubscribe\r\n$7\r\nchannel\r\n:1\r\n"
            + "*3\r\n$7\r\nmessage\r\n$7\r\nchannel\r\n$5\r\nvalue\r\n"
            + "+OK\r\n")));
    thread.process(connection);
    verify(listener).onSubscribe();
    verify(listener).onMessage(Strings.bytes("value"));
}