Merge branch 'executeStage' into 'master'

Execute stage

#120

See merge request !32

src/main/java/teetime/framework/AbstractConsumerStage.java

@@ -24,7 +24,7 @@ public abstract class AbstractConsumerStage<I> extends AbstractStage {
 	}
 
 	@Override
-	public final void executeWithPorts() {
+	public final void executeStage() {
 		final I element = this.getInputPort().receive();
 		if (null == element) {
 			returnNoElement();

src/main/java/teetime/framework/AbstractIntraThreadPipe.java

@@ -33,7 +33,7 @@ public abstract class AbstractIntraThreadPipe extends AbstractPipe {
 
 	@Override
 	public final void reportNewElement() {
-		this.cachedTargetStage.executeWithPorts();
+		this.cachedTargetStage.executeStage();
 	}
 
 	@Override

src/main/java/teetime/framework/AbstractProducerStage.java

@@ -33,7 +33,7 @@ public abstract class AbstractProducerStage<O> extends AbstractStage {
 	}
 
 	@Override
-	public void executeWithPorts() {
+	public void executeStage() {
 		this.execute();
 	}
 

src/main/java/teetime/framework/CompositeStage.java

@@ -43,8 +43,8 @@ public abstract class CompositeStage extends Stage {
 	protected abstract Collection<? extends Stage> getLastStages();
 
 	@Override
-	protected final void executeWithPorts() {
-		getFirstStage().executeWithPorts();
+	protected final void executeStage() {
+		getFirstStage().executeStage();
 	}
 
 	@Override

src/main/java/teetime/framework/RunnableConsumerStage.java

@@ -58,7 +58,7 @@ final class RunnableConsumerStage extends AbstractRunnableStage {
 	@Override
 	protected void executeStage(final Stage stage) {
 		try {
-			stage.executeWithPorts();
+			stage.executeStage();
 		} catch (NotEnoughInputException e) {
 			checkForTerminationSignal(stage);
 		}

src/main/java/teetime/framework/RunnableProducerStage.java

@@ -32,7 +32,7 @@ public final class RunnableProducerStage extends AbstractRunnableStage {
 
 	@Override
 	protected void executeStage(final Stage stage) {
-		stage.executeWithPorts();
+		stage.executeStage();
 	}
 
 	@Override

src/main/java/teetime/framework/Stage.java

@@ -96,7 +96,7 @@ public abstract class Stage {
 	 */
 	public abstract void validateOutputPorts(List<InvalidPortConnection> invalidPortConnections);
 
-	protected abstract void executeWithPorts();
+	protected abstract void executeStage();
 
 	protected abstract void onSignal(ISignal signal, InputPort<?> inputPort);
 

src/main/java/teetime/stage/basic/AbstractTrigger.java

@@ -32,7 +32,7 @@ abstract class AbstractTrigger<I, T, O> extends AbstractStage {
 	@SuppressWarnings("PMD.EmptyMethodInAbstractClassShouldBeAbstract")
 	// disabled while in development
 	@Override
-	protected void executeWithPorts() {
+	protected void executeStage() {
 		// TODO Auto-generated method stub
 
 	}

src/main/java/teetime/stage/basic/Delay.java

@@ -31,7 +31,7 @@ public final class Delay<T> extends AbstractStage {
 	private final List<T> bufferedElements = new LinkedList<T>();
 
 	@Override
-	public void executeWithPorts() {
+	public void executeStage() {
 		T element = inputPort.receive();
 		if (null != element) {
 			bufferedElements.add(element);

src/main/java/teetime/stage/basic/merger/Merger.java

@@ -54,7 +54,7 @@ public final class Merger<T> extends AbstractStage {
 	}
 
 	@Override
-	public void executeWithPorts() {
+	public void executeStage() {
 		final T token = this.strategy.getNextInput(this);
 		if (token == null) {
 			returnNoElement();

src/test/java/teetime/stage/basic/merger/MergerTest.java

@@ -57,8 +57,8 @@ public class MergerTest {
 	public void roundRobinShouldWork() {
 		mergerUnderTest.setStrategy(new RoundRobinStrategy());
 
-		this.fstProducer.executeWithPorts();
-		this.sndProducer.executeWithPorts();
+		this.fstProducer.executeStage();
+		this.sndProducer.executeStage();
 
 		assertThat(this.collector.getElements(), contains(1, 2, 3, 4, 5, 6));
 	}
@@ -67,7 +67,7 @@ public class MergerTest {
 	public void roundRobinWithSingleProducerShouldWork() {
 		mergerUnderTest.setStrategy(new RoundRobinStrategy());
 
-		this.fstProducer.executeWithPorts();
+		this.fstProducer.executeStage();
 
 		assertThat(this.collector.getElements(), contains(1, 2, 3));
 	}