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

minor refactoring

parent bdd068dc
No related branches found
No related tags found
No related merge requests found
...@@ -83,10 +83,6 @@ public abstract class AbstractCompositeStage { ...@@ -83,10 +83,6 @@ public abstract class AbstractCompositeStage {
* the type of elements to be sent * the type of elements to be sent
*/ */
protected <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity) { protected <T> void connectPorts(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity) {
connectPortsInternal(sourcePort, targetPort, capacity);
}
private final <T> void connectPortsInternal(final OutputPort<? extends T> sourcePort, final InputPort<T> targetPort, final int capacity) {
if (sourcePort.getOwningStage().getInputPorts().size() == 0) { if (sourcePort.getOwningStage().getInputPorts().size() == 0) {
if (sourcePort.getOwningStage().getOwningThread() == null) { if (sourcePort.getOwningStage().getOwningThread() == null) {
addThreadableStage(sourcePort.getOwningStage(), sourcePort.getOwningStage().getId()); addThreadableStage(sourcePort.getOwningStage(), sourcePort.getOwningStage().getId());
......
wiki @ 709c839c
Subproject commit 709c839c447a50c93b37fcc633a01297115d4823
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