in protonj2/src/main/java/org/apache/qpid/protonj2/buffer/ProtonBufferInputStream.java [223:258]
public String readLine() throws IOException {
checkClosed();
int available = available();
if (available == 0) {
return null;
}
loop: do {
final int c = buffer.readByte() & 0xff;
--available;
switch (c) {
case '\n':
break loop;
case '\r':
if (available > 0 && (char) buffer.getUnsignedByte(buffer.getReadOffset()) == '\n') {
buffer.advanceReadOffset(1);
--available;
}
break loop;
default:
if (readBuffer == null) {
readBuffer = new StringBuilder();
}
readBuffer.append((char) c);
}
} while (available > 0);
final String result = readBuffer != null && readBuffer.length() > 0 ? readBuffer.toString() : "";
if (readBuffer != null) {
readBuffer.setLength(0);
}
return result;
}