import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
import java.util.function.Function;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;
return Futures.catching(
super.handleServiceCall(input, isComplete),
Throwable.class,
- t -> RpcResultBuilder.<O>failed().build());
+ t -> RpcResultBuilder.<O>failed().build(), MoreExecutors.directExecutor());
}
}