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 a3e2023 minor clean up. done for the day. parallel() will have to wait. have it about 75% working. a3e2023 is described below commit a3e2023279bbea1e059d74e18fa6376ea99c9c26 Author: Marko A. Rodriguez <okramma...@gmail.com> AuthorDate: Wed Apr 3 15:22:34 2019 -0600 minor clean up. done for the day. parallel() will have to wait. have it about 75% working. --- .../main/java/org/apache/tinkerpop/machine/processor/rxjava/RxJava.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 cd81390..b665b41 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 @@ -69,7 +69,7 @@ public final class RxJava<C, S, E> implements Processor<C, S, E> { private void prepareFlow() { if (!this.executed) { this.executed = true; - TopologyUtil.compile(Flowable.fromIterable(this.starts), compilation). + TopologyUtil.compile(Flowable.fromIterable(this.starts), this.compilation). doOnNext(this.ends::add). doOnComplete(() -> this.alive.set(Boolean.FALSE)). subscribe();