Skip to content

Commit 75d1f85

Browse files
committed
addIdleTimeoutServerHandler -> addIdleTimeoutHandler
1 parent 07373f7 commit 75d1f85

File tree

3 files changed

+8
-8
lines changed

3 files changed

+8
-8
lines changed

reactor-netty-http/src/main/java/reactor/netty/http/IdleTimeoutHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
9898
* @param idleTimeout the idle timeout duration
9999
* @param httpConnectionLiveness the HTTP connection liveness checker
100100
*/
101-
public static void addIdleTimeoutServerHandler(ChannelPipeline pipeline, @Nullable Duration idleTimeout,
101+
public static void addIdleTimeoutHandler(ChannelPipeline pipeline, @Nullable Duration idleTimeout,
102102
HttpConnectionLiveness httpConnectionLiveness) {
103103
if (idleTimeout != null && pipeline.get(NettyPipeline.IdleTimeoutHandler) == null) {
104104
String baseName = null;

reactor-netty-http/src/main/java/reactor/netty/http/server/HttpServerConfig.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -658,7 +658,7 @@ static void configureHttp3Pipeline(
658658
p.remove(NettyPipeline.ChannelMetricsHandler);
659659
}
660660

661-
IdleTimeoutHandler.addIdleTimeoutServerHandler(
661+
IdleTimeoutHandler.addIdleTimeoutHandler(
662662
p,
663663
idleTimeout,
664664
new HttpConnectionImmediateClose()
@@ -724,7 +724,7 @@ static void configureH2Pipeline(ChannelPipeline p,
724724
cookieDecoder, cookieEncoder, formDecoderProvider, forwardedHeaderHandler, httpMessageLogFactory, listener,
725725
mapHandle, methodTagValue, metricsRecorder, minCompressionSize, opsFactory, readTimeout, requestTimeout, uriTagValue)));
726726

727-
IdleTimeoutHandler.addIdleTimeoutServerHandler(
727+
IdleTimeoutHandler.addIdleTimeoutHandler(
728728
p,
729729
idleTimeout,
730730
new Http2ConnectionLiveness(
@@ -840,7 +840,7 @@ else if (metricsRecorder instanceof ContextAwareHttpServerMetricsRecorder) {
840840
p.addBefore(NettyPipeline.ReactiveBridge, NettyPipeline.ErrorLogHandler, new DefaultErrorLogHandler(errorLog));
841841
}
842842

843-
IdleTimeoutHandler.addIdleTimeoutServerHandler(
843+
IdleTimeoutHandler.addIdleTimeoutHandler(
844844
p,
845845
idleTimeout,
846846
new HttpConnectionImmediateClose()
@@ -927,7 +927,7 @@ else if (metricsRecorder instanceof ContextAwareHttpServerMetricsRecorder) {
927927
p.addBefore(NettyPipeline.ReactiveBridge, NettyPipeline.ErrorLogHandler, new DefaultErrorLogHandler(errorLog));
928928
}
929929

930-
IdleTimeoutHandler.addIdleTimeoutServerHandler(
930+
IdleTimeoutHandler.addIdleTimeoutHandler(
931931
p,
932932
idleTimeout,
933933
new HttpConnectionImmediateClose()
@@ -1082,7 +1082,7 @@ public void handlerAdded(ChannelHandlerContext ctx) {
10821082

10831083
if (idleTimeout != null) {
10841084
IdleTimeoutHandler.removeIdleTimeoutHandler(pipeline);
1085-
IdleTimeoutHandler.addIdleTimeoutServerHandler(
1085+
IdleTimeoutHandler.addIdleTimeoutHandler(
10861086
pipeline,
10871087
idleTimeout,
10881088
new Http2ConnectionLiveness(

reactor-netty-http/src/main/java/reactor/netty/http/server/HttpTrafficHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -700,7 +700,7 @@ static boolean isMultipart(HttpResponse response) {
700700
private void setupIdleTimeoutHandler(ChannelPipeline pipeline) {
701701
Http2FrameCodec httpCodec = pipeline.get(Http2FrameCodec.class);
702702
if(httpCodec != null) {
703-
IdleTimeoutHandler.addIdleTimeoutServerHandler(
703+
IdleTimeoutHandler.addIdleTimeoutHandler(
704704
pipeline,
705705
idleTimeout,
706706
new Http2ConnectionLiveness(
@@ -713,7 +713,7 @@ private void setupIdleTimeoutHandler(ChannelPipeline pipeline) {
713713
return;
714714
}
715715

716-
IdleTimeoutHandler.addIdleTimeoutServerHandler(
716+
IdleTimeoutHandler.addIdleTimeoutHandler(
717717
pipeline,
718718
idleTimeout,
719719
new HttpConnectionImmediateClose()

0 commit comments

Comments
 (0)