This is an automated email from the ASF dual-hosted git repository.

ggregory pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/juneau.git

commit 0c37f204d35e5738c6f0281ee4a1f77be8f77542
Author: Gary Gregory <[email protected]>
AuthorDate: Fri Jun 23 22:53:11 2023 -0400

    [juneau-rest-server] Use lambdas
---
 .../java/org/apache/juneau/rest/RestRequest.java   | 47 ++++++++++------------
 .../apache/juneau/rest/arg/ResponseBeanArg.java    | 21 +++++-----
 .../apache/juneau/rest/arg/ResponseCodeArg.java    |  7 +---
 .../apache/juneau/rest/arg/ResponseHeaderArg.java  | 21 +++++-----
 4 files changed, 40 insertions(+), 56 deletions(-)

diff --git 
a/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/RestRequest.java
 
b/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/RestRequest.java
index 2467183e1..a714cfcdb 100644
--- 
a/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/RestRequest.java
+++ 
b/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/RestRequest.java
@@ -21,7 +21,6 @@ import static java.util.Optional.*;
 
 import java.io.*;
 import java.lang.reflect.*;
-import java.lang.reflect.Method;
 import java.lang.reflect.Proxy;
 import java.net.*;
 import java.nio.charset.*;
@@ -1523,31 +1522,27 @@ public final class RestRequest extends 
HttpServletRequestWrapper {
                        return (T)Proxy.newProxyInstance(
                                c.getClassLoader(),
                                new Class[] { c },
-                               new InvocationHandler() {
-                                       @Override /* InvocationHandler */
-                                       public Object invoke(Object proxy, 
Method method, Object[] args) throws Throwable {
-                                               RequestBeanPropertyMeta pm = 
rbm.getProperty(method.getName());
-                                               if (pm != null) {
-                                                       HttpPartParserSession 
pp = pm.getParser(getPartParserSession());
-                                                       HttpPartSchema schema = 
pm.getSchema();
-                                                       String name = 
pm.getPartName();
-                                                       ClassMeta<?> type = 
bs.getClassMeta(method.getGenericReturnType());
-                                                       HttpPartType pt = 
pm.getPartType();
-                                                       if (pt == 
HttpPartType.BODY)
-                                                               return 
getContent().setSchema(schema).as(type);
-                                                       if (pt == QUERY)
-                                                               return 
getQueryParam(name).parser(pp).schema(schema).as(type).orElse(null);
-                                                       if (pt == FORMDATA)
-                                                               return 
getFormParam(name).parser(pp).schema(schema).as(type).orElse(null);
-                                                       if (pt == HEADER)
-                                                               return 
getHeaderParam(name).parser(pp).schema(schema).as(type).orElse(null);
-                                                       if (pt == PATH)
-                                                               return 
getPathParam(name).parser(pp).schema(schema).as(type).orElse(null);
-                                               }
-                                               return null;
-                                       }
-
-                       });
+                               (InvocationHandler) (proxy, method, args) -> {
+                       RequestBeanPropertyMeta pm = 
rbm.getProperty(method.getName());
+                       if (pm != null) {
+                               HttpPartParserSession pp = 
pm.getParser(getPartParserSession());
+                               HttpPartSchema schema = pm.getSchema();
+                               String name = pm.getPartName();
+                               ClassMeta<?> type = 
bs.getClassMeta(method.getGenericReturnType());
+                               HttpPartType pt = pm.getPartType();
+                               if (pt == HttpPartType.BODY)
+                                       return 
getContent().setSchema(schema).as(type);
+                               if (pt == QUERY)
+                                       return 
getQueryParam(name).parser(pp).schema(schema).as(type).orElse(null);
+                               if (pt == FORMDATA)
+                                       return 
getFormParam(name).parser(pp).schema(schema).as(type).orElse(null);
+                               if (pt == HEADER)
+                                       return 
getHeaderParam(name).parser(pp).schema(schema).as(type).orElse(null);
+                               if (pt == PATH)
+                                       return 
getPathParam(name).parser(pp).schema(schema).as(type).orElse(null);
+                       }
+                       return null;
+                });
                } catch (Exception e) {
                        throw asRuntimeException(e);
                }
diff --git 
a/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseBeanArg.java
 
b/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseBeanArg.java
index d840450fe..a321949ef 100644
--- 
a/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseBeanArg.java
+++ 
b/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseBeanArg.java
@@ -71,18 +71,15 @@ public class ResponseBeanArg implements RestOpArg {
        @Override /* RestOpArg */
        public Object resolve(final RestOpSession opSession) throws Exception {
                Value<Object> v = new Value();
-               v.listener(new ValueListener() {
-                       @Override
-                       public void onSet(Object o) {
-                               RestRequest req = opSession.getRequest();
-                               RestResponse res = opSession.getResponse();
-                               ResponseBeanMeta meta = 
req.getOpContext().getResponseBeanMeta(o);
-                               if (meta == null)
-                                       meta = ResponseBeanArg.this.meta;
-                               res.setResponseBeanMeta(meta);
-                               res.setContent(o);
-                       }
-               });
+               v.listener(o -> {
+               RestRequest req = opSession.getRequest();
+               RestResponse res = opSession.getResponse();
+               ResponseBeanMeta meta = 
req.getOpContext().getResponseBeanMeta(o);
+               if (meta == null)
+                       meta = ResponseBeanArg.this.meta;
+               res.setResponseBeanMeta(meta);
+               res.setContent(o);
+        });
                return v;
        }
 }
diff --git 
a/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseCodeArg.java
 
b/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseCodeArg.java
index 6ddfafbca..03a924632 100644
--- 
a/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseCodeArg.java
+++ 
b/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseCodeArg.java
@@ -59,12 +59,7 @@ public class ResponseCodeArg implements RestOpArg {
        @Override /* RestOpArg */
        public Object resolve(final RestOpSession opSession) throws Exception {
                Value<Object> v = new Value();
-               v.listener(new ValueListener() {
-                       @Override
-                       public void onSet(Object o) {
-                               
opSession.getResponse().setStatus(Integer.parseInt(o.toString()));
-                       }
-               });
+               v.listener(o -> 
opSession.getResponse().setStatus(Integer.parseInt(o.toString())));
                return v;
        }
 }
diff --git 
a/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseHeaderArg.java
 
b/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseHeaderArg.java
index 3f50da126..5d99654a1 100644
--- 
a/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseHeaderArg.java
+++ 
b/juneau-rest/juneau-rest-server/src/main/java/org/apache/juneau/rest/arg/ResponseHeaderArg.java
@@ -81,18 +81,15 @@ public class ResponseHeaderArg implements RestOpArg {
        @Override /* RestOpArg */
        public Object resolve(final RestOpSession opSession) throws Exception {
                Value<Object> v = new Value();
-               v.listener(new ValueListener() {
-                       @Override
-                       public void onSet(Object o) {
-                               RestRequest req = opSession.getRequest();
-                               RestResponse res = opSession.getResponse();
-                               ResponsePartMeta rpm = 
req.getOpContext().getResponseHeaderMeta(o);
-                               if (rpm == null)
-                                       rpm = ResponseHeaderArg.this.meta;
-                               HttpPartSerializerSession pss = 
rpm.getSerializer() == null ? req.getPartSerializerSession() : 
rpm.getSerializer().getPartSession();
-                               res.setHeader(new SerializedHeader(name, o, 
pss, rpm.getSchema(), false));
-                       }
-               });
+               v.listener(o -> {
+               RestRequest req = opSession.getRequest();
+               RestResponse res = opSession.getResponse();
+               ResponsePartMeta rpm = 
req.getOpContext().getResponseHeaderMeta(o);
+               if (rpm == null)
+                       rpm = ResponseHeaderArg.this.meta;
+               HttpPartSerializerSession pss = rpm.getSerializer() == null ? 
req.getPartSerializerSession() : rpm.getSerializer().getPartSession();
+               res.setHeader(new SerializedHeader(name, o, pss, 
rpm.getSchema(), false));
+        });
                return v;
        }
 }

Reply via email to