infernap12/jdk
1
0
Fork 0
mirror of https://github.com/openjdk/jdk.git synced 2026-04-10 15:08:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove duplicate code in current()

Browse Source
This commit is contained in:
Daniel Jelinski 2026-01-30 09:59:10 +01:00
parent 52230a4858
commit 4ffa3e48c6
1 changed files with 8 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
test/jdk/java/net/httpclient/lib/jdk/httpclient/test/lib/http3/Http3ServerStreamImpl.java
View File

@ -301,27 +301,16 @@ final class Http3ServerStreamImpl {
ByteBuffer current;
ByteBuffer current() throws IOException {
Object reason = closeReason.get();
if (reason != null) {
if (reason == Boolean.TRUE) {
throw new IOException("Stream is closed");
} else {
throw new IOException((IOException)reason);
}
}
while (true) {
if (current != null && current.hasRemaining()) {
return current;
}
if (current == QuicStreamReader.EOF) {
reason = closeReason.get();
if (reason != null) {
if (reason == Boolean.TRUE) {
throw new IOException("Stream is closed");
} else {
throw new IOException((IOException)reason);
}
Object reason = closeReason.get();
if (reason != null) {
if (reason == Boolean.TRUE) {
throw new IOException("Stream is closed");
} else {
throw new IOException((IOException)reason);
}
}
if (current != null && (current.hasRemaining() || current == QuicStreamReader.EOF)) {
return current;
}
try {