Skip to content
This repository was archived by the owner on Jun 21, 2023. It is now read-only.

Commit 97fd15f

Browse files
committed
Removed onNextDropped from gateway client transport
1 parent 7ebe738 commit 97fd15f

File tree

1 file changed

+0
-10
lines changed

1 file changed

+0
-10
lines changed

services-gateway-client-transport/src/main/java/io/scalecube/services/gateway/transport/GatewayClientTransports.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
import io.netty.buffer.ByteBuf;
44
import io.rsocket.Payload;
5-
import io.scalecube.services.api.ServiceMessage;
65
import io.scalecube.services.gateway.transport.http.HttpGatewayClient;
76
import io.scalecube.services.gateway.transport.http.HttpGatewayClientCodec;
87
import io.scalecube.services.gateway.transport.rsocket.RSocketGatewayClient;
@@ -12,22 +11,13 @@
1211
import io.scalecube.services.transport.api.ClientTransport;
1312
import io.scalecube.services.transport.api.DataCodec;
1413
import io.scalecube.services.transport.api.HeadersCodec;
15-
import io.scalecube.services.transport.api.ReferenceCountUtil;
1614
import java.util.function.Function;
17-
import reactor.core.publisher.Hooks;
1815

1916
public class GatewayClientTransports {
2017

2118
private static final String CONTENT_TYPE = "application/json";
2219
private static final HeadersCodec HEADERS_CODEC = HeadersCodec.getInstance(CONTENT_TYPE);
2320

24-
static {
25-
Hooks.onNextDropped(
26-
obj ->
27-
ReferenceCountUtil.safestRelease(
28-
obj instanceof ServiceMessage ? ((ServiceMessage) obj).data() : obj));
29-
}
30-
3121
public static final GatewayClientCodec<ByteBuf> WEBSOCKET_CLIENT_CODEC =
3222
new WebsocketGatewayClientCodec(DataCodec.getInstance(CONTENT_TYPE));
3323
public static final GatewayClientCodec<Payload> RSOCKET_CLIENT_CODEC =

0 commit comments

Comments
 (0)