From d6e6f1f584d9994525a1e4dfab30afbfd2f8bf4f Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Mon, 23 Feb 2015 19:40:13 +0100
Subject: [PATCH] added a test for correct start and termination
---
.../teetime/framework/RunnableConsumerStageTest.java | 10 ++++++++++
.../RunnableConsumerStageTestConfiguration.java | 4 +++-
2 files changed, 13 insertions(+), 1 deletion(-)
diff --git a/src/test/java/teetime/framework/RunnableConsumerStageTest.java b/src/test/java/teetime/framework/RunnableConsumerStageTest.java
index 225eac81..fc92dcc6 100644
--- a/src/test/java/teetime/framework/RunnableConsumerStageTest.java
+++ b/src/test/java/teetime/framework/RunnableConsumerStageTest.java
@@ -54,6 +54,16 @@ public class RunnableConsumerStageTest {
thread.join();
}
+ @Test
+ public void testCorrectStartAndTerminatation() throws Exception {
+ RunnableConsumerStageTestConfiguration configuration = new RunnableConsumerStageTestConfiguration(0, 1, 2, 3, 5);
+
+ final Analysis analysis = new Analysis(configuration);
+ start(analysis);
+
+ assertEquals(5, configuration.getCollectedElements().size());
+ }
+
// @Test
// public void testWaitingInfinitely() throws Exception {
// WaitStrategyConfiguration waitStrategyConfiguration = new WaitStrategyConfiguration(300, 42);
diff --git a/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java b/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
index 1eb57d6b..0631e81b 100644
--- a/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
+++ b/src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java
@@ -16,7 +16,9 @@ public class RunnableConsumerStageTestConfiguration extends AnalysisConfiguratio
public RunnableConsumerStageTestConfiguration(final Integer... inputElements) {
InitialElementProducer<Integer> producer = new InitialElementProducer<Integer>(inputElements);
- // addThreadableStage(producer);
+ if (inputElements.length > 0) {
+ addThreadableStage(producer);
+ }
CollectorSink<Integer> collectorSink = new CollectorSink<Integer>(collectedElements);
addThreadableStage(collectorSink);
--
GitLab