diff options
Diffstat (limited to 'java/src')
| -rw-r--r-- | java/src/Ice/src/main/java/com/zeroc/IceInternal/InvocationFutureI.java | 23 |
1 files changed, 3 insertions, 20 deletions
diff --git a/java/src/Ice/src/main/java/com/zeroc/IceInternal/InvocationFutureI.java b/java/src/Ice/src/main/java/com/zeroc/IceInternal/InvocationFutureI.java index 3be5400e401..951a103fe44 100644 --- a/java/src/Ice/src/main/java/com/zeroc/IceInternal/InvocationFutureI.java +++ b/java/src/Ice/src/main/java/com/zeroc/IceInternal/InvocationFutureI.java @@ -133,30 +133,13 @@ public abstract class InvocationFutureI<T> extends com.zeroc.Ice.InvocationFutur // calling thread if the request was sent synchronously. Calling complete() or // completeExceptionally() on _sentFuture invokes the action from this thread. // - if(_sentSynchronously) + if(_exception != null) { - if(_exception != null) - { - _sentFuture.completeExceptionally(_exception); - } - else - { - _sentFuture.complete(_sentSynchronously); - } + _sentFuture.completeExceptionally(_exception); } else { - if(_exception != null) - { - dispatch(() -> - { - _sentFuture.completeExceptionally(_exception); - }); - } - else - { - invokeSentAsync(); - } + _sentFuture.complete(_sentSynchronously); } } return r; |