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

go back to using CompletableFuture (sigh)

Browse source
This commit is contained in:
Vaci Koblizek 2020-10-24 16:44:38 +01:00
parent c903cbf193
commit f2b2fc769f
2 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -77,10 +77,10 @@ public interface ClientHook {
} }
final class VoidPromiseAndPipeline { final class VoidPromiseAndPipeline {
public final CompletionStage<java.lang.Void> promise; public final CompletableFuture<java.lang.Void> promise;
public final PipelineHook pipeline; public final PipelineHook pipeline;
VoidPromiseAndPipeline(CompletionStage<java.lang.Void> promise, PipelineHook pipeline) { VoidPromiseAndPipeline(CompletableFuture<java.lang.Void> promise, PipelineHook pipeline) {
this.promise = promise; this.promise = promise;
this.pipeline = pipeline; this.pipeline = pipeline;
} }

5
runtime/src/main/java/org/capnproto/RemotePromise.java
View file

@ -1,14 +1,15 @@
package org.capnproto; package org.capnproto;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage; import java.util.concurrent.CompletionStage;
public class RemotePromise<Results> public class RemotePromise<Results>
extends CompletableFutureWrapper<Results> { extends CompletableFutureWrapper<Results> {
final CompletionStage<Response<Results>> response; final CompletableFuture<Response<Results>> response;
final PipelineHook hook; final PipelineHook hook;
RemotePromise(CompletionStage<Response<Results>> promise, RemotePromise(CompletableFuture<Response<Results>> promise,
PipelineHook hook) { PipelineHook hook) {
super(promise.thenApply(response -> response.getResults())); super(promise.thenApply(response -> response.getResults()));
this.response = promise; this.response = promise;