[tinkerpop] branch tp4 updated: fixed a bug in Pipes.subscribe().

[okram]

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 576f880  fixed a bug in Pipes.subscribe().
576f880 is described below

commit 576f880e5918b0912fa8b9bdf531d24e116be3ba
Author: Marko A. Rodriguez <okramma...@gmail.com>
AuthorDate: Tue Apr 23 06:54:50 2019 -0600

    fixed a bug in Pipes.subscribe().
---
 .../src/main/java/org/apache/tinkerpop/machine/processor/beam/Beam.java | 2 +-
 .../main/java/org/apache/tinkerpop/machine/processor/pipes/Pipes.java   | 1 -
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/java/machine/processor/beam/src/main/java/org/apache/tinkerpop/machine/processor/beam/Beam.java
 
b/java/machine/processor/beam/src/main/java/org/apache/tinkerpop/machine/processor/beam/Beam.java
index 20007c4..0bb39fe 100644
--- 
a/java/machine/processor/beam/src/main/java/org/apache/tinkerpop/machine/processor/beam/Beam.java
+++ 
b/java/machine/processor/beam/src/main/java/org/apache/tinkerpop/machine/processor/beam/Beam.java
@@ -89,7 +89,7 @@ public class Beam<C, S, E> implements Processor<C, S, E> {
     @Override
     public void stop() {
         try {
-            if (null != this.pipelineResult)
+            if (this.isRunning())
                 this.pipelineResult.cancel();
         } catch (final IOException e) {
             throw new RuntimeException(e.getMessage(), e);
diff --git 
a/java/machine/processor/pipes/src/main/java/org/apache/tinkerpop/machine/processor/pipes/Pipes.java
 
b/java/machine/processor/pipes/src/main/java/org/apache/tinkerpop/machine/processor/pipes/Pipes.java
index 317659f..cc5a4cf 100644
--- 
a/java/machine/processor/pipes/src/main/java/org/apache/tinkerpop/machine/processor/pipes/Pipes.java
+++ 
b/java/machine/processor/pipes/src/main/java/org/apache/tinkerpop/machine/processor/pipes/Pipes.java
@@ -115,7 +115,6 @@ public final class Pipes<C, S, E> implements Processor<C, 
S, E> {
         if (this.isRunning())
             throw Processor.Exceptions.processorIsCurrentlyRunning(this);
 
-        this.alive.set(Boolean.TRUE);
         new Thread(() -> {
             final Iterator<Traverser<C, E>> iterator = this.iterator(starts);
             while (iterator.hasNext()) {