Skip to content
Snippets Groups Projects
Commit b5a7eaf1 authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa
Browse files

added some test methods for InitialElementProducer #113

parent f25c732e
No related branches found
No related tags found
No related merge requests found
...@@ -16,7 +16,6 @@ ...@@ -16,7 +16,6 @@
package teetime.stage; package teetime.stage;
import java.util.Arrays; import java.util.Arrays;
import java.util.List;
import teetime.framework.AbstractProducerStage; import teetime.framework.AbstractProducerStage;
...@@ -56,19 +55,4 @@ public final class InitialElementProducer<T> extends AbstractProducerStage<T> { ...@@ -56,19 +55,4 @@ public final class InitialElementProducer<T> extends AbstractProducerStage<T> {
this.elements = elements; this.elements = elements;
} }
public static void main(final String[] args) {
// int[] array = new int[] { 0, 0, 0 };
// new IterableProducer<Integer>(array);
//
// new InitialElementProducer<Integer>(array);
Integer[] array = new Integer[] { 0, 0, 0 };
new InitialElementProducer<Integer>(array);
new InitialElementProducer<Integer>(0, 0, 0);
List<Integer> iterable = Arrays.asList(0, 0, 0);
new InitialElementProducer<Integer>(iterable);
}
} }
...@@ -24,7 +24,6 @@ import static teetime.framework.test.StageTester.test; ...@@ -24,7 +24,6 @@ import static teetime.framework.test.StageTester.test;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import org.junit.Before;
import org.junit.Test; import org.junit.Test;
/** /**
...@@ -34,13 +33,14 @@ public class InitialElementProducerTest { ...@@ -34,13 +33,14 @@ public class InitialElementProducerTest {
private InitialElementProducer<Integer> producer; private InitialElementProducer<Integer> producer;
@Before // @Before
public void initializeProducer() { public void initializeProducer() {
producer = new InitialElementProducer<Integer>(); producer = new InitialElementProducer<Integer>();
} }
@Test @Test
public void producerShouldByDefaultSendNothing() { public void producerShouldByDefaultSendNothing() {
initializeProducer();
List<Integer> results = new ArrayList<Integer>(); List<Integer> results = new ArrayList<Integer>();
test(producer).and().receive(results).from(producer.getOutputPort()).start(); test(producer).and().receive(results).from(producer.getOutputPort()).start();
...@@ -48,7 +48,8 @@ public class InitialElementProducerTest { ...@@ -48,7 +48,8 @@ public class InitialElementProducerTest {
} }
@Test @Test
public void producerShouldSendDefinedValues() { public void testSetIterArray() {
initializeProducer();
producer.setIter(new Integer[] { 1, 2, 3 }); producer.setIter(new Integer[] { 1, 2, 3 });
List<Integer> results = new ArrayList<Integer>(); List<Integer> results = new ArrayList<Integer>();
...@@ -56,4 +57,44 @@ public class InitialElementProducerTest { ...@@ -56,4 +57,44 @@ public class InitialElementProducerTest {
assertThat(results, contains(1, 2, 3)); assertThat(results, contains(1, 2, 3));
} }
@Test
public void testSetIterVarargs() {
initializeProducer();
producer.setIter(1, 2, 3);
List<Integer> results = new ArrayList<Integer>();
test(producer).and().receive(results).from(producer.getOutputPort()).start();
assertThat(results, contains(1, 2, 3));
}
@Test
public void instantiateWithArray() {
producer = new InitialElementProducer<Integer>(new Integer[] { 1, 2, 3 });
List<Integer> results = new ArrayList<Integer>();
test(producer).and().receive(results).from(producer.getOutputPort()).start();
assertThat(results, contains(1, 2, 3));
}
@Test
public void instantiateWithVarargs() {
producer = new InitialElementProducer<Integer>(1, 2, 3);
List<Integer> results = new ArrayList<Integer>();
test(producer).and().receive(results).from(producer.getOutputPort()).start();
assertThat(results, contains(1, 2, 3));
}
@Test
public void instantiateWithIterable() {
List<Integer> test = new ArrayList<Integer>();
test.add(1);
test.add(2);
test.add(3);
producer = new InitialElementProducer<Integer>(test);
List<Integer> results = new ArrayList<Integer>();
test(producer).and().receive(results).from(producer.getOutputPort()).start();
assertThat(results, contains(1, 2, 3));
}
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment