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

Compare commits

base: open-autonomous-connection:1.0.1-BETA.0.3
Branches Tags
open-autonomous-connection:master open-autonomous-connection:dev open-autonomous-connection:classic
open-autonomous-connection:1.0.1-BETA.0.4 open-autonomous-connection:1.0.1-BETA.0.3 open-autonomous-connection:1.0.1-BETA open-autonomous-connection:1.0.0-BETA
..
compare: open-autonomous-connection:1.0.1-BETA.0.4
Branches Tags
open-autonomous-connection:master open-autonomous-connection:dev open-autonomous-connection:classic
open-autonomous-connection:1.0.1-BETA.0.4 open-autonomous-connection:1.0.1-BETA.0.3 open-autonomous-connection:1.0.1-BETA open-autonomous-connection:1.0.0-BETA

1 Commits
1.0.1-BETA ... 1.0.1-BETA

Author SHA1 Message Date
UnlegitDqrk
ba44cd6f7d Updated to new Protocol Build 2026-02-28 15:35:57 +01:00
2 changed files with 5 additions and 6 deletions
Expand all files Collapse all files

4
pom.xml
View File

@@ -6,7 +6,7 @@
<groupId>org.openautonomousconnection</groupId>
<artifactId>WebClient</artifactId>
<version>1.0.1-BETA.0.3</version>
<version>1.0.1-BETA.0.4</version>
<organization>
<name>Open Autonomous Connection</name>
<url>https://open-autonomous-connection.org/</url>
@@ -79,7 +79,7 @@
<dependency>
<groupId>org.openautonomousconnection</groupId>
<artifactId>Protocol</artifactId>
<version>1.0.1-BETA.0.5</version>
<version>1.0.1-BETA.0.6</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>

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;