|
|
|
@ -30,7 +30,6 @@ import reactor.ipc.netty.http.server.HttpServerResponse; |
|
|
|
|
import org.springframework.core.io.buffer.DataBuffer; |
|
|
|
|
import org.springframework.core.io.buffer.DataBufferFactory; |
|
|
|
|
import org.springframework.core.io.buffer.NettyDataBufferFactory; |
|
|
|
|
import org.springframework.http.HttpHeaders; |
|
|
|
|
import org.springframework.http.HttpStatus; |
|
|
|
|
import org.springframework.http.ResponseCookie; |
|
|
|
|
import org.springframework.http.ZeroCopyHttpOutputMessage; |
|
|
|
@ -84,10 +83,6 @@ public class ReactorServerHttpResponse extends AbstractServerHttpResponse |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
protected void applyHeaders() { |
|
|
|
|
// TODO: temporarily, see https://github.com/reactor/reactor-netty/issues/2
|
|
|
|
|
if(getHeaders().containsKey(HttpHeaders.CONTENT_LENGTH)){ |
|
|
|
|
this.response.disableChunkedTransfer(); |
|
|
|
|
} |
|
|
|
|
for (String name : getHeaders().keySet()) { |
|
|
|
|
for (String value : getHeaders().get(name)) { |
|
|
|
|
this.response.responseHeaders().add(name, value); |
|
|
|
|