Skip to content

Commit f5af960

Browse files
author
OlegDokuka
committed
logs
Signed-off-by: Oleh Dokuka <odokuka@vmware.com> Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com> Signed-off-by: OlegDokuka <odokuka@vmware.com>
1 parent 59cfe88 commit f5af960

File tree

1 file changed

+37
-0
lines changed

1 file changed

+37
-0
lines changed

rsocket-core/src/main/java/io/rsocket/core/RSocketRequester.java

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,43 @@ class RSocketRequester extends RequesterResponderSupport implements RSocket {
7373
private final Mono<Void> onAllClosed;
7474
private final KeepAliveFramesAcceptor keepAliveFramesAcceptor;
7575

76+
RSocketRequester(
77+
DuplexConnection connection,
78+
PayloadDecoder payloadDecoder,
79+
StreamIdSupplier streamIdSupplier,
80+
int mtu,
81+
int maxFrameLength,
82+
int maxInboundPayloadSize,
83+
int keepAliveTickPeriod,
84+
int keepAliveAckTimeout,
85+
@Nullable KeepAliveHandler keepAliveHandler,
86+
Function<RSocket, RequestInterceptor> requestInterceptorFunction,
87+
@Nullable RequesterLeaseTracker requesterLeaseTracker,
88+
Sinks.Empty<Void> onGracefulShutdownStartedSink,
89+
Sinks.Empty<Void> onGracefulShutdownSink,
90+
Sinks.Empty<Void> onThisSideClosedSink,
91+
Mono<Void> onGracefulShutdownDone,
92+
Mono<Void> onAllClosed) {
93+
this(
94+
"",
95+
connection,
96+
payloadDecoder,
97+
streamIdSupplier,
98+
mtu,
99+
maxFrameLength,
100+
maxInboundPayloadSize,
101+
keepAliveTickPeriod,
102+
keepAliveAckTimeout,
103+
keepAliveHandler,
104+
requestInterceptorFunction,
105+
requesterLeaseTracker,
106+
onGracefulShutdownStartedSink,
107+
onGracefulShutdownSink,
108+
onThisSideClosedSink,
109+
onGracefulShutdownDone,
110+
onAllClosed);
111+
}
112+
76113
RSocketRequester(
77114
String stack,
78115
DuplexConnection connection,

0 commit comments

Comments
 (0)