From c7d43f7be43939d60452e91bdf5370a51e05932b Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Fri, 26 Jun 2015 09:03:16 +0200
Subject: [PATCH] minor refactoring
---
.../basic/distributor/dynamic/DynamicDistributor.java | 2 +-
.../basic/merger/dynamic/ControlledMergerTest.java | 10 ++++++----
2 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/src/main/java/teetime/stage/basic/distributor/dynamic/DynamicDistributor.java b/src/main/java/teetime/stage/basic/distributor/dynamic/DynamicDistributor.java
index ab49def6..72cf755a 100644
--- a/src/main/java/teetime/stage/basic/distributor/dynamic/DynamicDistributor.java
+++ b/src/main/java/teetime/stage/basic/distributor/dynamic/DynamicDistributor.java
@@ -16,7 +16,7 @@ public class DynamicDistributor<T> extends Distributor<T> implements OutputPortR
protected final BlockingQueue<PortAction<DynamicDistributor<T>>> portActions;
public DynamicDistributor() {
- portActions = PortActionHelper.createPortActionQueue();
+ this.portActions = PortActionHelper.createPortActionQueue();
addOutputPortRemovedListener(this);
}
diff --git a/src/test/java/teetime/stage/basic/merger/dynamic/ControlledMergerTest.java b/src/test/java/teetime/stage/basic/merger/dynamic/ControlledMergerTest.java
index 03cd01b4..2304e0fa 100644
--- a/src/test/java/teetime/stage/basic/merger/dynamic/ControlledMergerTest.java
+++ b/src/test/java/teetime/stage/basic/merger/dynamic/ControlledMergerTest.java
@@ -25,13 +25,15 @@ public class ControlledMergerTest {
@Test
public void shouldWorkWithoutActionTriggers() throws Exception {
- PortAction<DynamicMerger<Integer>> createAction = new DoNothingPortAction<Integer>();
-
List<Integer> inputNumbers = Arrays.asList(0, 1, 2, 3, 4);
+
@SuppressWarnings("unchecked")
- List<PortAction<DynamicMerger<Integer>>> inputActions = Arrays.asList(createAction, createAction, createAction, createAction, createAction);
+ PortAction<DynamicMerger<Integer>>[] inputActions = new PortAction[5];
+ for (int i = 0; i < inputActions.length; i++) {
+ inputActions[i] = new DoNothingPortAction<Integer>();
+ }
- ControlledMergerTestConfig<Integer> config = new ControlledMergerTestConfig<Integer>(inputNumbers, inputActions);
+ ControlledMergerTestConfig<Integer> config = new ControlledMergerTestConfig<Integer>(inputNumbers, Arrays.asList(inputActions));
Execution<ControlledMergerTestConfig<Integer>> analysis = new Execution<ControlledMergerTestConfig<Integer>>(config,
new TerminatingExceptionListenerFactory());
--
GitLab