Update UpgradeInputStream.java

This commit is contained in:
Josiah Noel 2026-02-11 13:47:58 -05:00
parent 4956aed7ce
commit dccd8469ce
2 changed files with 4 additions and 2 deletions

View File

@ -281,7 +281,7 @@ class ExchangeImpl {
o.setWrappedStream(new UndefLengthOutputStream(this, ros));
close = true;
} else if (upgrade && rCode == 101) {
o.setWrappedStream (new UpgradeOutputStream (this, ros));
o.setWrappedStream (new UpgradeOutputStream(this, ros));
close = true;
} else {
rspHdrs.set("Transfer-encoding", "chunked");

View File

@ -62,7 +62,9 @@ class UpgradeInputStream extends LeftOverInputStream {
@Override
public void close() throws IOException {
closed = true;
t.getServerImpl().requestCompleted(t.getConnection());
if(t.getConnection().state == State.REQUEST) {
t.getServerImpl().requestCompleted(t.getConnection());
}
}
@Override