This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch 3.2
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.2 by this push:
new 2ad601372d add xds futrue note (#10760)
2ad601372d is described below
commit 2ad601372d93cac0f53e7e42a35ea8cd7fa1786c
Author: wucheng1997 <[email protected]>
AuthorDate: Wed Oct 19 10:55:26 2022 +0800
add xds futrue note (#10760)
---
.../org/apache/dubbo/registry/xds/util/protocol/AbstractProtocol.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/dubbo-xds/src/main/java/org/apache/dubbo/registry/xds/util/protocol/AbstractProtocol.java
b/dubbo-xds/src/main/java/org/apache/dubbo/registry/xds/util/protocol/AbstractProtocol.java
index 2d6dcb040b..4c87033109 100644
---
a/dubbo-xds/src/main/java/org/apache/dubbo/registry/xds/util/protocol/AbstractProtocol.java
+++
b/dubbo-xds/src/main/java/org/apache/dubbo/registry/xds/util/protocol/AbstractProtocol.java
@@ -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);