Fixing residual code smells

sashirestela · Mar 19, 2024 · c81b6a1 · c81b6a1
1 parent cf6a6e4
commit c81b6a1
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 10 deletions.
diff --git a/src/main/java/io/github/sashirestela/cleverclient/metadata/InterfaceMetadataStore.java b/src/main/java/io/github/sashirestela/cleverclient/metadata/InterfaceMetadataStore.java
@@ -12,6 +12,7 @@
 import org.slf4j.LoggerFactory;
 
 import java.lang.annotation.Annotation;
+import java.lang.reflect.Method;
 import java.lang.reflect.Parameter;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -79,12 +80,7 @@ private List<AnnotationMetadata> getAnnotations(Annotation[] javaAnnotations) {
         for (var javaAnnotation : javaAnnotations) {
             Map<String, String> valueByField = new HashMap<>();
             for (var javaAnnotMethod : javaAnnotation.annotationType().getDeclaredMethods()) {
-                Object object;
-                try {
-                    object = javaAnnotMethod.invoke(javaAnnotation, (Object[]) null);
-                } catch (Exception e) {
-                    object = null;
-                }
+                Object object = getAnnotationValue(javaAnnotation, javaAnnotMethod);
                 if (object instanceof Annotation[]) {
                     isAnnotArray = true;
                     annotations.addAll(getAnnotations((Annotation[]) object));
@@ -142,4 +138,14 @@ private void validate(InterfaceMetadata interfaceMetadata) {
         });
     }
 
+    private Object getAnnotationValue(Annotation javaAnnotation, Method javaAnnotMethod) {
+        Object object;
+        try {
+            object = javaAnnotMethod.invoke(javaAnnotation, (Object[]) null);
+        } catch (Exception e) {
+            object = null;
+        }
+        return object;
+    }
+
 }
diff --git a/src/main/java/io/github/sashirestela/cleverclient/sender/HttpAsyncStreamSender.java b/src/main/java/io/github/sashirestela/cleverclient/sender/HttpAsyncStreamSender.java
@@ -23,11 +23,11 @@ public <S, T> Object sendRequest(HttpClient httpClient, HttpRequest httpRequest,
             final var lineRecord = new CleverClientSSE.LineRecord();
 
             return response.body()
-                    .peek(line -> {
+                    .map(line -> {
                         logger.debug("Response : {}", line);
                         lineRecord.updateWith(line);
+                        return new CleverClientSSE(lineRecord);
                     })
-                    .map(line -> new CleverClientSSE(lineRecord))
                     .filter(CleverClientSSE::isActualData)
                     .map(item -> JsonUtil.jsonToObject(item.getActualData(), responseClass));
         });

diff --git a/src/main/java/io/github/sashirestela/cleverclient/sender/HttpSyncStreamSender.java b/src/main/java/io/github/sashirestela/cleverclient/sender/HttpSyncStreamSender.java
@@ -24,11 +24,11 @@ public <S, T> Object sendRequest(HttpClient httpClient, HttpRequest httpRequest,
             final var lineRecord = new CleverClientSSE.LineRecord();
 
             return httpResponse.body()
-                    .peek(line -> {
+                    .map(line -> {
                         logger.debug("Response : {}", line);
                         lineRecord.updateWith(line);
+                        return new CleverClientSSE(lineRecord);
                     })
-                    .map(line -> new CleverClientSSE(lineRecord))
                     .filter(CleverClientSSE::isActualData)
                     .map(item -> JsonUtil.jsonToObject(item.getActualData(), responseClass));