Spring-cloud-gateway: Can I write response body before setComplete?

[maoyunfei]

I hava a customer filter, I want to return specified content such as "Hello World", but I can only get response status code 502 without response content. Where is wrong?

@Component
public class CustomerFilter implements GatewayFilter {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        byte[] bytes = "Hello World".getBytes(StandardCharsets.UTF_8);
        DataBuffer buffer = exchange.getResponse().bufferFactory().wrap(bytes);
        exchange.getResponse().writeWith(Flux.just(buffer));
        exchange.getResponse().setStatusCode(HttpStatus.BAD_GATEWAY);
        return exchange.getResponse().setComplete();
    }
}

[maoyunfei]

If I don't call exchange.getResponse().setComplete() , it works, I get response body "Hello World",
can anyone explain it ?

@Component
public class CustomerFilter implements GatewayFilter {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        byte[] bytes = "Hello World".getBytes(StandardCharsets.UTF_8);
        DataBuffer buffer = exchange.getResponse().bufferFactory().wrap(bytes);
        exchange.getResponse().setStatusCode(HttpStatus.BAD_GATEWAY);
        return exchange.getResponse().writeWith(Flux.just(buffer));
    }
}

[re6exp]

The manual is here and here.
Spring cloud gateway is not based on spring MVC but on spring webflux. Or, in short, there is no need to call setComplete manually.

[hitos]

If I don't call exchange.getResponse().setComplete() , it works, I get response body "Hello World",
can anyone explain it ?

@Component
public class CustomerFilter implements GatewayFilter {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        byte[] bytes = "Hello World".getBytes(StandardCharsets.UTF_8);
        DataBuffer buffer = exchange.getResponse().bufferFactory().wrap(bytes);
        exchange.getResponse().setStatusCode(HttpStatus.BAD_GATEWAY);
        return exchange.getResponse().writeWith(Flux.just(buffer));
    }
}

thanks