diff --git a/pom.xml b/pom.xml index 91b39cf..eceae76 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ org.openautonomousconnection WebClient - 1.0.1-BETA.0.3 + 1.0.1-BETA.0.4 Open Autonomous Connection https://open-autonomous-connection.org/ @@ -79,7 +79,7 @@ org.openautonomousconnection Protocol - 1.0.1-BETA.0.5 + 1.0.1-BETA.0.6 org.projectlombok diff --git a/src/main/java/org/openautonomousconnection/webclient/ClientImpl.java b/src/main/java/org/openautonomousconnection/webclient/ClientImpl.java index c421af4..460847c 100644 --- a/src/main/java/org/openautonomousconnection/webclient/ClientImpl.java +++ b/src/main/java/org/openautonomousconnection/webclient/ClientImpl.java @@ -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 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;