You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@curator.apache.org by ra...@apache.org on 2017/06/30 04:21:07 UTC
[2/2] curator git commit: completeChildrenAsZNodes() wasn't handling
empty children listsw
completeChildrenAsZNodes() wasn't handling empty children listsw
Project: http://git-wip-us.apache.org/repos/asf/curator/repo
Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/7e6551f3
Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/7e6551f3
Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/7e6551f3
Branch: refs/heads/CURATOR-397
Commit: 7e6551f3fe3f1abbcf797739df20acc5a4e5be16
Parents: 738c361
Author: randgalt <ra...@apache.org>
Authored: Thu Jun 29 23:21:02 2017 -0500
Committer: randgalt <ra...@apache.org>
Committed: Thu Jun 29 23:21:02 2017 -0500
----------------------------------------------------------------------
.../curator/x/async/modeled/details/ModeledFrameworkImpl.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/curator/blob/7e6551f3/curator-x-async/src/main/java/org/apache/curator/x/async/modeled/details/ModeledFrameworkImpl.java
----------------------------------------------------------------------
diff --git a/curator-x-async/src/main/java/org/apache/curator/x/async/modeled/details/ModeledFrameworkImpl.java b/curator-x-async/src/main/java/org/apache/curator/x/async/modeled/details/ModeledFrameworkImpl.java
index 4951478..c1d19c4 100644
--- a/curator-x-async/src/main/java/org/apache/curator/x/async/modeled/details/ModeledFrameworkImpl.java
+++ b/curator-x-async/src/main/java/org/apache/curator/x/async/modeled/details/ModeledFrameworkImpl.java
@@ -251,6 +251,11 @@ public class ModeledFrameworkImpl<T> implements ModeledFramework<T>
private void completeChildrenAsZNodes(ModelStage<List<ZNode<T>>> modelStage, List<ZPath> children)
{
List<ZNode<T>> nodes = Lists.newArrayList();
+ if ( children.size() == 0 )
+ {
+ modelStage.complete(nodes);
+ return;
+ }
children.forEach(path -> withPath(path).readAsZNode().handle((node, e) -> {
if ( e != null )
{