You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by ok...@apache.org on 2019/04/03 21:04:24 UTC
[tinkerpop] branch tp4 updated: fixed a bug where repeat loops
weren't being updated in RxJava.
This is an automated email from the ASF dual-hosted git repository.
okram pushed a commit to branch tp4
in repository https://gitbox.apache.org/repos/asf/tinkerpop.git
The following commit(s) were added to refs/heads/tp4 by this push:
new b01672b fixed a bug where repeat loops weren't being updated in RxJava.
b01672b is described below
commit b01672b067195df27f17755ebb56d0d16e00e8d5
Author: Marko A. Rodriguez <ok...@gmail.com>
AuthorDate: Wed Apr 3 15:04:14 2019 -0600
fixed a bug where repeat loops weren't being updated in RxJava.
---
.../tinkerpop/machine/processor/rxjava/util/TopologyUtil.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/util/TopologyUtil.java b/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/util/TopologyUtil.java
index 4146623..a9bee79 100644
--- a/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/util/TopologyUtil.java
+++ b/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/util/TopologyUtil.java
@@ -126,16 +126,16 @@ public final class TopologyUtil {
list.add(List.of(0, t.repeatDone(repeatBranch)));
} else if (4 == repeatBranch.getEmitLocation() && repeatBranch.getEmit().filterTraverser(t)) {
list.add(List.of(0, t.repeatDone(repeatBranch)));
- list.add(List.of(1, t));
+ list.add(List.of(1, t.repeatLoop(repeatBranch)));
} else
- list.add(List.of(1, t));
+ list.add(List.of(1, t.repeatLoop(repeatBranch)));
} else if (3 == repeatBranch.getEmitLocation()) {
if (repeatBranch.getEmit().filterTraverser(t))
list.add(List.of(0, t.repeatDone(repeatBranch)));
if (4 == repeatBranch.getUntilLocation() && repeatBranch.getUntil().filterTraverser(t))
list.add(List.of(0, t.repeatDone(repeatBranch)));
else
- list.add(List.of(1, t));
+ list.add(List.of(1, t.repeatLoop(repeatBranch)));
}
} else
list.add(List.of(1, t.repeatLoop(repeatBranch)));