import io.netty.handler.codec.ReplayingDecoder;
import java.io.IOException;
public class RedisReplyDecoder extends ReplayingDecoder<Reply<?>, Void> {
private MultiBulkReply reply;
public ByteBuf readBytes(ByteBuf is) throws IOException {
<BUG>int size = Decoders.readInteger(is);

if (size == -1) {</BUG>
return null;
}

import io.netty.handler.codec.ReplayingDecoder;
import java.io.IOException;
public class RedisReplyDecoder extends ReplayingDecoder<Reply<?>, Void> {
private MultiBulkReply reply;
public ByteBuf readBytes(ByteBuf is) throws IOException {
long l = Decoders.readLong(is);
if (l > Integer.MAX_VALUE) {
throw new IOException("Value too large");
}
int size = (int) l;
if (size == -1) {
return null;
}
