From 57d46f59868b35b327cdeead4838fbf2ad33448d Mon Sep 17 00:00:00 2001 From: Vadim Tkachenko Date: Thu, 29 Aug 2024 23:55:58 -0700 Subject: [PATCH] Now exercising ZERO_COPY on the client side as well as server (#323) --- .../homeclimatecontrol/hcc/client/rsocket/RSocketClient.java | 2 ++ 1 file changed, 2 insertions(+) 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 index 9c37dfcd..e6dddc66 100644 --- 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 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();