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);
 

Reply via email to