[tinkerpop] branch tp4 updated: minor clean up. done for the day. parallel() will have to wait. have it about 75% working.

[ok...@apache.org]

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 <ok...@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();