Skip to content

Commit 49b0df4

Browse files
committed
Changed frameDecoder to default (lots of leaks were found)
1 parent 00b36a2 commit 49b0df4

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketClientTransport.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ private Mono<RSocket> connect(Address address, Map<Address, Mono<RSocket>> monoM
4949

5050
Mono<RSocket> rsocketMono =
5151
RSocketFactory.connect()
52-
.frameDecoder(PayloadDecoder.ZERO_COPY)
52+
.frameDecoder(PayloadDecoder.DEFAULT)
5353
.errorConsumer(
5454
th -> LOGGER.warn("Exception occurred at rsocket client transport: " + th))
5555
.transport(() -> TcpClientTransport.create(tcpClient))

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketServerTransport.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public Mono<ServerTransport> bind(ServiceMethodRegistry methodRegistry) {
5454
});
5555

5656
return RSocketFactory.receive()
57-
.frameDecoder(PayloadDecoder.ZERO_COPY)
57+
.frameDecoder(PayloadDecoder.DEFAULT)
5858
.errorConsumer(
5959
th -> LOGGER.warn("Exception occurred at rsocket server transport: " + th))
6060
.acceptor(new RSocketServiceAcceptor(codec, methodRegistry))

0 commit comments

Comments
 (0)