Update BeanAdapter and Pipe.

Author: gk-brown

build.gradle

@@ -14,7 +14,7 @@
 
 subprojects {
     group = 'org.httprpc'
-    version = '4.9.3'
+    version = '4.9.4'
 
     apply plugin: 'java-library'
 

kilo-client/src/main/java/org/httprpc/kilo/beans/BeanAdapter.java

@@ -1044,15 +1044,15 @@ private static Object toRawType(Object value, Class<?> type) {
             } else if (type.isEnum()) {
                 return toEnum(value.toString(), type);
             } else {
-                if (value instanceof Map<?, ?> map) {
-                    if (type.isRecord()) {
-                        return toRecord(map, type);
-                    } else {
-                        return toBean(map, type);
-                    }
-                } else {
+                if (!(value instanceof Map<?, ?> map)) {
                     throw new IllegalArgumentException("Value is not a map.");
                 }
+
+                if (type.isRecord()) {
+                    return toRecord(map, type);
+                } else {
+                    return toBean(map, type);
+                }
             }
         }
     }
@@ -1267,7 +1267,7 @@ private static String getPropertyName(Method method) {
 
         String prefix;
         if (methodName.startsWith(GET_PREFIX)
-            && !(returnType == Void.TYPE || returnType == Void.class)
+            && returnType != Void.TYPE && returnType != Void.class
             && parameterCount == 0) {
             prefix = GET_PREFIX;
         } else if (methodName.startsWith(IS_PREFIX)
@@ -1279,10 +1279,6 @@ private static String getPropertyName(Method method) {
             && parameterCount == 1) {
             prefix = SET_PREFIX;
         } else {
-            prefix = null;
-        }
-
-        if (prefix == null) {
             return null;
         }
 

kilo-client/src/main/java/org/httprpc/kilo/util/concurrent/Pipe.java

@@ -145,7 +145,9 @@ private void submit(Object value) {
             if (timeout == 0) {
                 queue.put(value);
             } else {
-                if (!queue.offer(value, timeout, TimeUnit.MILLISECONDS)) {
+                var result = queue.offer(value, timeout, TimeUnit.MILLISECONDS);
+
+                if (!result) {
                     throw new TimeoutException("Offer timed out.");
                 }
             }