From 25954c8952a67efc76e875eb557f234dffb2a9b5 Mon Sep 17 00:00:00 2001 From: Spencer Gibb Date: Thu, 25 Jul 2019 13:27:01 -0400 Subject: [PATCH] Removes missing method/class --- .../cloud/gateway/filter/NettyRoutingFilter.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/NettyRoutingFilter.java b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/NettyRoutingFilter.java index c1001338..6e56b7d5 100644 --- a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/NettyRoutingFilter.java +++ b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/NettyRoutingFilter.java @@ -25,7 +25,6 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; -import reactor.netty.NettyPipeline; import reactor.netty.http.client.HttpClient; import reactor.netty.http.client.HttpClientResponse; @@ -131,10 +130,9 @@ public class NettyRoutingFilter implements GlobalFilter, Ordered { + connection.channel().id().asShortText() + ", inbound: " + exchange.getLogPrefix())); } - return nettyOutbound.options(NettyPipeline.SendOptions::flushOnEach) - .send(request.getBody() - .map(dataBuffer -> ((NettyDataBuffer) dataBuffer) - .getNativeBuffer())); + return nettyOutbound.send(request.getBody() + .map(dataBuffer -> ((NettyDataBuffer) dataBuffer) + .getNativeBuffer())); }).responseConnection((res, connection) -> { // Defer committing the response until all route filters have run