diff --git a/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/WebsocketRoutingFilter.java b/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/WebsocketRoutingFilter.java index 8286e7d3..c6e61b82 100644 --- a/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/WebsocketRoutingFilter.java +++ b/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/WebsocketRoutingFilter.java @@ -217,7 +217,8 @@ public class WebsocketRoutingFilter implements GlobalFilter, Ordered { // Ensure closeStatus from one propagates to the other Mono.when(serverClose, proxyClose).subscribe(); // Complete when both sessions are done - return Mono.zip(proxySessionSend, serverSessionSend).then(); } + return Mono.zip(proxySessionSend, serverSessionSend).then(); + } /** * Copy subProtocols so they are available downstream.