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

move more CompFutures to void

Browse source
This commit is contained in:
Vaci Koblizek 2020-10-21 21:37:22 +01:00
parent 6d082a71b5
commit 05dc84b675
3 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
runtime/src/main/java/org/capnproto/CallContext.java
View file

@ -32,7 +32,7 @@ public class CallContext<Params, Results> {
return this.hook.getResults().initAs(results); return this.hook.getResults().initAs(results);
} }
public final <SubParams, Results> CompletableFuture<?> tailCall(Request<SubParams, Results> tailRequest) { public final <SubParams, Results> CompletableFuture<java.lang.Void> tailCall(Request<SubParams, Results> tailRequest) {
return this.hook.tailCall(tailRequest.getHook()); return this.hook.tailCall(tailRequest.getHook());
} }

2
runtime/src/main/java/org/capnproto/CallContextHook.java
View file

@ -13,7 +13,7 @@ public interface CallContextHook {
AnyPointer.Builder getResults(int sizeHint); AnyPointer.Builder getResults(int sizeHint);
CompletableFuture<?> tailCall(RequestHook request); CompletableFuture<java.lang.Void> tailCall(RequestHook request);
void allowCancellation(); void allowCancellation();

8
runtime/src/main/java/org/capnproto/PipelineHook.java
View file

@ -1,10 +1,14 @@
package org.capnproto; package org.capnproto;
public interface PipelineHook { public interface PipelineHook {
ClientHook getPipelinedCap(PipelineOp[] ops); ClientHook getPipelinedCap(PipelineOp[] ops);
static PipelineHook newBrokenPipeline(Throwable exc) { static PipelineHook newBrokenPipeline(Throwable exc) {
return ops -> Capability.newBrokenCap(exc); return new PipelineHook() {
@Override
public ClientHook getPipelinedCap(PipelineOp[] ops) {
return Capability.newBrokenCap(exc);
}
};
} }
} }