in chill-protobuf/src/main/java/com/twitter/chill/protobuf/ProtobufSerializer.java [80:92]
public Message read(Kryo kryo, Input input, Class<Message> pbClass) {
try {
int size = input.readInt(true);
if (size == 0) {
return (Message) getDefaultInstance(pbClass).invoke(null);
}
byte[] barr = new byte[size];
input.readBytes(barr);
return (Message)getParse(pbClass).invoke(null, barr);
} catch (Exception e) {
throw new RuntimeException("Could not create " + pbClass, e);
}
}