AbstractParser.java 文件源码

@Override
public MessageType parsePartialDelimitedFrom(
    InputStream input, ExtensionRegistryLite extensionRegistry)
    throws InvalidProtocolBufferException {
  int size;
  try {
    int firstByte = input.read();
    if (firstByte == -1) {
      return null;
    }
    size = CodedInputStream.readRawVarint32(firstByte, input);
  } catch (IOException e) {
    throw new InvalidProtocolBufferException(e);
  }
  InputStream limitedInput = new LimitedInputStream(input, size);
  return parsePartialFrom(limitedInput, extensionRegistry);
}