tinkerpop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ok...@apache.org
Subject [tinkerpop] branch tp4 updated: fixed a bug where repeat loops weren't being updated in RxJava.
Date Wed, 03 Apr 2019 21:04:24 GMT
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 <okrammarko@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)));


Mime
View raw message