serverscanning/capnproto-java-rpc
16
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

make direct call if QueuedClient has resolved

Browse source
This commit is contained in:
Vaci Koblizek 2020-12-01 17:12:49 +00:00
parent 3b1f5f416c
commit 53eeed97e2
1 changed files with 4 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
runtime/src/main/java/org/capnproto/Capability.java
View file

@ -782,18 +782,16 @@ public final class Capability {
@Override @Override
public VoidPromiseAndPipeline call(long interfaceId, short methodId, CallContextHook ctx) { public VoidPromiseAndPipeline call(long interfaceId, short methodId, CallContextHook ctx) {
var promise = new CompletableFuture<ClientHook>(); if (this.redirect != null) {
if (this.redirect == null) { return this.redirect.call(interfaceId, methodId, ctx);
this.queuedCalls.add(promise);
}
else {
promise.complete(this.redirect);
} }
var promise = new CompletableFuture<ClientHook>();
var callResult = promise.thenApply( var callResult = promise.thenApply(
client -> client.call(interfaceId, methodId, ctx)); client -> client.call(interfaceId, methodId, ctx));
var pipelineResult = callResult.thenApply(result -> result.pipeline); var pipelineResult = callResult.thenApply(result -> result.pipeline);
var pipeline = new QueuedPipeline(pipelineResult); var pipeline = new QueuedPipeline(pipelineResult);
this.queuedCalls.add(promise);
return new VoidPromiseAndPipeline(pipelineResult.thenRun(() -> {}), pipeline); return new VoidPromiseAndPipeline(pipelineResult.thenRun(() -> {}), pipeline);
} }