Browse Source

cache reactor request methods

pull/30158/head
James Yuzawa 3 years ago committed by Arjen Poutsma
parent
commit
c27a5687dc
  1. 5
      spring-web/src/main/java/org/springframework/http/server/reactive/ReactorNetty2ServerHttpRequest.java
  2. 5
      spring-web/src/main/java/org/springframework/http/server/reactive/ReactorServerHttpRequest.java

5
spring-web/src/main/java/org/springframework/http/server/reactive/ReactorNetty2ServerHttpRequest.java

@ -63,6 +63,8 @@ class ReactorNetty2ServerHttpRequest extends AbstractServerHttpRequest { @@ -63,6 +63,8 @@ class ReactorNetty2ServerHttpRequest extends AbstractServerHttpRequest {
private final Netty5DataBufferFactory bufferFactory;
private final HttpMethod method;
public ReactorNetty2ServerHttpRequest(HttpServerRequest request, Netty5DataBufferFactory bufferFactory)
throws URISyntaxException {
@ -71,6 +73,7 @@ class ReactorNetty2ServerHttpRequest extends AbstractServerHttpRequest { @@ -71,6 +73,7 @@ class ReactorNetty2ServerHttpRequest extends AbstractServerHttpRequest {
Assert.notNull(bufferFactory, "DataBufferFactory must not be null");
this.request = request;
this.bufferFactory = bufferFactory;
this.method = HttpMethod.valueOf(request.method().name());
}
private static URI initUri(HttpServerRequest request) throws URISyntaxException {
@ -141,7 +144,7 @@ class ReactorNetty2ServerHttpRequest extends AbstractServerHttpRequest { @@ -141,7 +144,7 @@ class ReactorNetty2ServerHttpRequest extends AbstractServerHttpRequest {
@Override
public HttpMethod getMethod() {
return HttpMethod.valueOf(this.request.method().name());
return this.method;
}
@Override

5
spring-web/src/main/java/org/springframework/http/server/reactive/ReactorServerHttpRequest.java

@ -61,6 +61,8 @@ class ReactorServerHttpRequest extends AbstractServerHttpRequest { @@ -61,6 +61,8 @@ class ReactorServerHttpRequest extends AbstractServerHttpRequest {
private final NettyDataBufferFactory bufferFactory;
private final HttpMethod method;
public ReactorServerHttpRequest(HttpServerRequest request, NettyDataBufferFactory bufferFactory)
throws URISyntaxException {
@ -69,6 +71,7 @@ class ReactorServerHttpRequest extends AbstractServerHttpRequest { @@ -69,6 +71,7 @@ class ReactorServerHttpRequest extends AbstractServerHttpRequest {
Assert.notNull(bufferFactory, "DataBufferFactory must not be null");
this.request = request;
this.bufferFactory = bufferFactory;
this.method = HttpMethod.valueOf(request.method().name());
}
private static URI initUri(HttpServerRequest request) throws URISyntaxException {
@ -111,7 +114,7 @@ class ReactorServerHttpRequest extends AbstractServerHttpRequest { @@ -111,7 +114,7 @@ class ReactorServerHttpRequest extends AbstractServerHttpRequest {
@Override
public HttpMethod getMethod() {
return HttpMethod.valueOf(this.request.method().name());
return this.method;
}
@Override

Loading…
Cancel
Save