Fix error handling in callback API

ballerina-platform · Apr 10, 2024 · 42da72a · 42da72a
1 parent 023da0f
commit 42da72a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/native/src/main/java/io/ballerina/lib/confluent/avro/serdes/ExecutionCallback.java b/native/src/main/java/io/ballerina/lib/confluent/avro/serdes/ExecutionCallback.java
@@ -39,12 +39,12 @@ public class ExecutionCallback implements Callback {
     }
 
     @Override
-    public void notifySuccess(Object o) {
-        try {
-            Object jsonObject = JsonUtils.parse(StringUtils.getJsonString(o));
+    public void notifySuccess(Object result) {
+        if (result instanceof BError) {
+            this.future.complete(result);
+        } else {
+            Object jsonObject = JsonUtils.parse(StringUtils.getJsonString(result));
             this.future.complete(ValueUtils.convert(jsonObject, typeDesc.getDescribingType()));
-        } catch (BError e) {
-            this.future.complete(e);
         }
     }
 

diff --git a/native/src/main/java/module-info.java b/native/src/main/java/module-info.java
@@ -16,7 +16,7 @@
  * under the License.
  */
 
-module io.ballerina.stdlib.serdes {
+module io.ballerina.lib.serdes {
     requires io.ballerina.runtime;
     requires io.ballerina.lang;
     requires org.apache.avro;