New methods in GroupProcessor

For faster shortcuts in the Groovy bridge

Core/src/ca/uqac/lif/cep/GroupProcessor.java

@@ -500,6 +500,31 @@ protected void associateEndpoints(GroupProcessor group,
 			group.associateOutput(output_number, clone_p, pa.m_ioNumber);
 		}
 	}
+
+	public Processor in(Processor p)
+	{
+		addProcessor(p);
+		associateInput(p);
+		return p;
+	}
+
+	public Processor out(Processor p)
+	{
+		addProcessor(p);
+		associateOutput(p);
+		collectProcessors(p);
+		return p;
+	}
+
+	/**
+	 * Crawls the network of processors and adds to {@link #m_processors} any
+	 * processor that is not already present in the list.
+	 * @param start The starting point of the collection
+	 */
+	protected void collectProcessors(Processor start)
+	{
+		new CollectCrawler().crawl(start);;
+	}
 
 	/**
 	 * Creates a copy of a processor.
@@ -599,6 +624,21 @@ public void visit(Processor p)
 			}
 		}
 	}
+
+	/**
+	 * A crawler that adds to the group any processor it encounters.
+	 */
+	protected class CollectCrawler extends PipeCrawler
+	{
+		@Override
+		public void visit(Processor p)
+		{
+			if (!m_processors.contains(p))
+			{
+				m_processors.add(p);
+			}
+		}
+	}
 
 	@Override
 	public void setContext(Context context)