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/04 12:40:23 UTC
[tinkerpop] branch tp4 updated: renamed ReduceFlow in RxJava to
Reducer as its not a Flow.
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 4302a2f renamed ReduceFlow in RxJava to Reducer as its not a Flow.
4302a2f is described below
commit 4302a2f6894520acd5615ca62a21e882186e48c7
Author: Marko A. Rodriguez <ok...@gmail.com>
AuthorDate: Thu Apr 4 06:40:14 2019 -0600
renamed ReduceFlow in RxJava to Reducer as its not a Flow.
---
.../machine/processor/rxjava/{ReduceFlow.java => Reducer.java} | 4 ++--
.../java/org/apache/tinkerpop/machine/processor/rxjava/RxJava.java | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/ReduceFlow.java b/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/Reducer.java
similarity index 89%
rename from java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/ReduceFlow.java
rename to java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/Reducer.java
index 145d22d..6aab534 100644
--- a/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/ReduceFlow.java
+++ b/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/Reducer.java
@@ -25,11 +25,11 @@ import org.apache.tinkerpop.machine.traverser.Traverser;
/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
*/
-final class ReduceFlow<C, S, E> implements BiFunction<Traverser<C, E>, Traverser<C, S>, Traverser<C, E>> {
+final class Reducer<C, S, E> implements BiFunction<Traverser<C, E>, Traverser<C, S>, Traverser<C, E>> {
private final ReduceFunction<C, S, E> function;
- ReduceFlow(final ReduceFunction<C, S, E> function) {
+ Reducer(final ReduceFunction<C, S, E> function) {
this.function = function;
}
diff --git a/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/RxJava.java b/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/RxJava.java
index e4a050e..b7eac76 100644
--- a/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/RxJava.java
+++ b/java/machine/processor/rxjava/src/main/java/org/apache/tinkerpop/machine/processor/rxjava/RxJava.java
@@ -120,7 +120,7 @@ public final class RxJava<C, S, E> implements Processor<C, S, E> {
return Flowable.fromIterable(() -> IteratorUtils.map(((InitialFunction<C, E>) function).get(), s -> traverserFactory.create(function, s)));
} else if (function instanceof ReduceFunction) {
final ReduceFunction<C, S, E> reduceFunction = (ReduceFunction<C, S, E>) function;
- return flow.reduce(traverserFactory.create(reduceFunction, reduceFunction.getInitialValue()), new ReduceFlow<>(reduceFunction)).toFlowable();
+ return flow.reduce(traverserFactory.create(reduceFunction, reduceFunction.getInitialValue()), new Reducer<>(reduceFunction)).toFlowable();
} else if (function instanceof BarrierFunction) {
final BarrierFunction<C, S, E, B> barrierFunction = (BarrierFunction<C, S, E, B>) function;
return flow.reduce(barrierFunction.getInitialValue(), new Barrier<>(barrierFunction)).toFlowable().flatMapIterable(new BarrierFlow<>(barrierFunction, traverserFactory));