natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add xds futrue note (#10760)

This commit is contained in:
wucheng1997 2022-10-19 10:55:26 +08:00 committed by GitHub
parent c65754681c
commit 2ad601372d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dubbo-xds/src/main/java/org/apache/dubbo/registry/xds/util/protocol/AbstractProtocol.java
View File

@ -147,7 +147,7 @@ public abstract class AbstractProtocol<T, S extends DeltaResource<T>> implements
// origin request, may changed by updateObserve
Set<String> names = requestParam.get(request);
// use future to get async result
// use future to get async result, future complete on StreamObserver onNext
CompletableFuture<T> future = new CompletableFuture<>();
streamResult.put(request, future);