open-autonomous-connection/WebClient
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

Updated to new Protocol Build

Browse Source
This commit is contained in:
UnlegitDqrk
2026-02-28 15:35:57 +01:00
parent 35cd895510
commit ba44cd6f7d
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/openautonomousconnection/webclient/ClientImpl.java
View File

@@ -10,6 +10,7 @@ import org.openautonomousconnection.protocol.packets.v1_0_1.beta.web.impl.resour
import org.openautonomousconnection.protocol.side.client.ProtocolClient;
import org.openautonomousconnection.protocol.side.client.ProtocolWebClient;
import org.openautonomousconnection.protocol.side.client.events.ConnectedToProtocolINSServerEvent;
import org.openautonomousconnection.protocol.side.client.events.ConnectedToProtocolServerEvent;
import org.openautonomousconnection.protocol.urlhandler.v1_0_1.beta.LibClientImpl_v1_0_1_B;
import org.openautonomousconnection.protocol.urlhandler.v1_0_1.beta.web.WebFlagInspector;
import org.openautonomousconnection.protocol.urlhandler.v1_0_1.beta.web.WebRequestContextProvider;
@@ -195,6 +196,7 @@ public final class ClientImpl extends ProtocolWebClient {
Map<String, String> headers,
long totalLength) {
System.out.println("stream start");
if (streams.size() >= MAX_CONCURRENT_STREAMS) {
throw new IllegalStateException("Too many concurrent streams");
}
@@ -205,7 +207,6 @@ public final class ClientImpl extends ProtocolWebClient {
@Override
public void streamChunk(WebPacketHeader header, int seq, byte[] data) {
StreamState state = streams.get(new StreamKey(header));
if (state == null) {
throw new IllegalStateException("Chunk without streamStart");
@@ -216,7 +217,6 @@ public final class ClientImpl extends ProtocolWebClient {
@Override
public void streamEnd(WebPacketHeader header, boolean ok, String error) {
StreamState state = streams.get(new StreamKey(header));
if (state != null) {
state.markEnd(ok, error);
@@ -224,8 +224,7 @@ public final class ClientImpl extends ProtocolWebClient {
}
@Override
public void streamFinish(WebPacketHeader header, byte[] ignored) {
public void streamFinish(WebPacketHeader header, byte[] data) {
StreamKey key = new StreamKey(header);
StreamState state = streams.remove(key);
if (state == null) return;