Cosmetic changes to have less changes with master

scalecube · Oct 1, 2024 · 143679d · 143679d
1 parent b5a9cf8
commit 143679d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/...teway/src/main/java/io/scalecube/services/gateway/client/http/HttpGatewayClientCodec.java b/...teway/src/main/java/io/scalecube/services/gateway/client/http/HttpGatewayClientCodec.java
@@ -43,7 +43,7 @@ public ByteBuf encode(ServiceMessage message) {
  }
 
  @Override
- public ServiceMessage decode(ByteBuf byteBuf) {
- return ServiceMessage.builder().data(byteBuf).build();
+ public ServiceMessage decode(ByteBuf encodedMessage) {
+ return ServiceMessage.builder().data(encodedMessage).build();
  }
 }
diff --git a/...main/java/io/scalecube/services/gateway/client/websocket/WebsocketGatewayClientCodec.java b/...main/java/io/scalecube/services/gateway/client/websocket/WebsocketGatewayClientCodec.java
@@ -106,8 +106,8 @@ public ByteBuf encode(ServiceMessage message) {
  }
 
  @Override
- public ServiceMessage decode(ByteBuf byteBuf) {
- try (InputStream stream = new ByteBufInputStream(byteBuf, true)) {
+ public ServiceMessage decode(ByteBuf encodedMessage) {
+ try (InputStream stream = new ByteBufInputStream(encodedMessage, true)) {
  JsonParser jp = jsonFactory.createParser(stream);
  ServiceMessage.Builder result = ServiceMessage.builder();
 
@@ -141,7 +141,7 @@ public ServiceMessage decode(ByteBuf byteBuf) {
  }
  // data
  if (dataEnd > dataStart) {
- result.data(byteBuf.copy((int) dataStart, (int) (dataEnd - dataStart)));
+ result.data(encodedMessage.copy((int) dataStart, (int) (dataEnd - dataStart)));
  }
  return result.build();
  } catch (Throwable ex) {