forces TcpDuplexConnection to use connection allocator

Signed-off-by: Oleh Dokuka <[email protected]>
gzlicanyi · Apr 27, 2020 · ad12ddd · ad12ddd
1 parent a81b639
commit ad12ddd
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/TcpDuplexConnection.java b/rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/TcpDuplexConnection.java
@@ -31,7  31,6 @@
 public final class TcpDuplexConnection extends BaseDuplexConnection {
 
   private final Connection connection;
-  private final ByteBufAllocator allocator = ByteBufAllocator.DEFAULT;
   private final boolean encodeLength;
 
   /**
@@ -89,7  88,7 @@ public Mono<Void> send(Publisher<ByteBuf> frames) {
 
   private ByteBuf encode(ByteBuf frame) {
     if (encodeLength) {
-      return FrameLengthFlyweight.encode(allocator, frame.readableBytes(), frame);
       return FrameLengthFlyweight.encode(alloc(), frame.readableBytes(), frame);
     } else {
       return frame;
     }