Now exercising ZERO_COPY on the client side as well as server (#323)

home-climate-control · Aug 30, 2024 · 57d46f5 · 57d46f5
1 parent b867aa9
commit 57d46f5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/app/hcc-cli/src/main/java/com/homeclimatecontrol/hcc/client/rsocket/RSocketClient.java b/app/hcc-cli/src/main/java/com/homeclimatecontrol/hcc/client/rsocket/RSocketClient.java
@@ -5,6 +5,7 @@
 import io.netty.buffer.ByteBufAllocator;
 import io.netty.buffer.ByteBufUtil;
 import io.rsocket.core.RSocketConnector;
+import io.rsocket.frame.decoder.PayloadDecoder;
 import io.rsocket.metadata.TaggingMetadataCodec;
 import io.rsocket.metadata.WellKnownMimeType;
 import io.rsocket.transport.netty.client.TcpClientTransport;
@@ -31,6 +32,7 @@ public List<ZoneStatus> getZones(String bindAddress, int port, String serializat
 
         var socket = RSocketConnector
                 .create()
+                .payloadDecoder(PayloadDecoder.ZERO_COPY)
                 .metadataMimeType(WellKnownMimeType.MESSAGE_RSOCKET_ROUTING.getString())
                 .connect(TcpClientTransport.create(bindAddress, port))
                 .block();