From 6cd843dfbdc676ac586477f5c9dc24e081c3a778 Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <stu103017@mail.uni-kiel.de>
Date: Tue, 26 May 2015 13:18:43 +0200
Subject: [PATCH] changed to correct generic types
---
.../java/teetime/framework/AnalysisConfiguration.java | 10 +++++++---
1 file changed, 7 insertions(+), 3 deletions(-)
diff --git a/src/main/java/teetime/framework/AnalysisConfiguration.java b/src/main/java/teetime/framework/AnalysisConfiguration.java
index b7c758ae..bcf85239 100644
--- a/src/main/java/teetime/framework/AnalysisConfiguration.java
+++ b/src/main/java/teetime/framework/AnalysisConfiguration.java
@@ -32,7 +32,7 @@ import teetime.util.Pair;
public abstract class AnalysisConfiguration {
private final List<Stage> threadableStageJobs = new LinkedList<Stage>();
- private final List<Pair<Stage, Stage>> connections = new LinkedList<Pair<Stage, Stage>>();
+ private final List<Pair<OutputPort, InputPort>> connections = new LinkedList<Pair<OutputPort, InputPort>>();
@SuppressWarnings("deprecation")
private static final PipeFactoryRegistry PIPE_FACTORY_REGISTRY = PipeFactoryRegistry.INSTANCE;
@@ -141,12 +141,16 @@ public abstract class AnalysisConfiguration {
return interUnboundedThreadFactory.create(sourcePort, targetPort, capacity);
}
+ protected <T> void connectStages(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort) {
+ connections.add(new Pair<OutputPort, InputPort>(sourcePort, targetPort));
+ }
+
/**
* Returns a list of pairs, which describe the connections among all stages.
*
- * @return a list of pairs of stages, which are connected
+ * @return a list of pairs of Out- and InputPorts, which are connected
*/
- protected List<Pair<Stage, Stage>> getConnections() {
+ protected List<Pair<OutputPort, InputPort>> getConnections() {
return connections;
}
--
GitLab