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

use getHook() accessor

Browse source
This commit is contained in:
Vaci Koblizek 2020-10-21 21:29:41 +01:00
parent c01228c31c
commit 6d082a71b5
2 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -6,18 +6,18 @@ public class CallContext<Params, Results> {
private final FromPointerReader<Params> params; private final FromPointerReader<Params> params;
private final FromPointerBuilder<Results> results; private final FromPointerBuilder<Results> results;
final CallContextHook hook; private final CallContextHook hook;
public CallContext(FromPointerReader<Params> params, public CallContext(FromPointerReader<Params> params,
FromPointerBuilder<Results> results, FromPointerBuilder<Results> results,
CallContextHook hook) { CallContextHook hook) {
this.hook = hook;
this.params = params; this.params = params;
this.results = results; this.results = results;
this.hook = hook;
} }
public final Params getParams() { public final Params getParams() {
return hook.getParams().getAs(params); return this.hook.getParams().getAs(params);
} }
public final void releaseParams() { public final void releaseParams() {
@ -33,7 +33,7 @@ public class CallContext<Params, Results> {
} }
public final <SubParams, Results> CompletableFuture<?> tailCall(Request<SubParams, Results> tailRequest) { public final <SubParams, Results> CompletableFuture<?> tailCall(Request<SubParams, Results> tailRequest) {
return hook.tailCall(tailRequest.getHook()); return this.hook.tailCall(tailRequest.getHook());
} }
public final void allowCancellation() { public final void allowCancellation() {

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

@ -199,13 +199,13 @@ public final class Capability {
FromPointerReader<Params> paramsFactory, FromPointerReader<Params> paramsFactory,
FromPointerBuilder<Results> resultsFactory, FromPointerBuilder<Results> resultsFactory,
CallContext<AnyPointer.Reader, AnyPointer.Builder> typeless) { CallContext<AnyPointer.Reader, AnyPointer.Builder> typeless) {
return new CallContext<>(paramsFactory, resultsFactory, typeless.hook); return new CallContext<>(paramsFactory, resultsFactory, typeless.getHook());
} }
protected static <Params> StreamingCallContext<Params> internalGetTypedStreamingContext( protected static <Params> StreamingCallContext<Params> internalGetTypedStreamingContext(
FromPointerReader<Params> paramsFactory, FromPointerReader<Params> paramsFactory,
CallContext<AnyPointer.Reader, AnyPointer.Builder> typeless) { CallContext<AnyPointer.Reader, AnyPointer.Builder> typeless) {
return new StreamingCallContext<>(paramsFactory, typeless.hook); return new StreamingCallContext<>(paramsFactory, typeless.getHook());
} }
protected abstract DispatchCallResult dispatchCall( protected abstract DispatchCallResult dispatchCall(