RC

meteor-core/src/main/java/dev/pixelib/meteor/core/trackers/OutgoingInvocationTracker.java

@@ -50,18 +50,21 @@ public <T> T invokeRemoteMethod(InvocationDescriptor invocationDescriptor) throw
         }
     }
 
-    public void completeInvocation(InvocationResponse invocationResponse) {
+    public boolean completeInvocation(InvocationResponse invocationResponse) {
         // do we have a pending invocation for this invocation id?
         PendingInvocation<?> pendingInvocation = pendingInvocations.get(invocationResponse.getInvocationId());
         if (pendingInvocation == null) {
-            throw new IllegalStateException("No pending invocation found for invocation id " + invocationResponse.getInvocationId() + ". Data: " + invocationResponse.getResult());
-            //return;
+            // we cannot handle this invocation, so it must be handled in another listener
+            return false;
         }
 
         pendingInvocation.complete(invocationResponse.getResult());
 
         // remove the pending invocation from the map
         pendingInvocations.remove(invocationResponse.getInvocationId());
+
+        // invocation was successfully completed
+        return true;
     }
 
 }

meteor-core/src/main/java/dev/pixelib/meteor/core/transport/TransportHandler.java

@@ -49,8 +49,7 @@ public TransportHandler(
 
     private boolean handleInvocationResponse(byte[] bytes) throws ClassNotFoundException {
         InvocationResponse invocationResponse = InvocationResponse.fromBytes(serializer, bytes);
-        outgoingInvocationTracker.completeInvocation(invocationResponse);
-        return true;
+        return outgoingInvocationTracker.completeInvocation(invocationResponse);
     }
 
     private boolean handleInvocationRequest(byte[] bytes) throws ClassNotFoundException {