TestSinkStage sink = new TestSinkStage<String>();
StreamGraph graph = new StreamGraph();
graph.addHead( source1 );
graph.addHead( source2 );
graph.addPath( source1, 0, gate );
graph.addPath( source2, 1, gate );
graph.addPath( gate, stage1 );
graph.addPath( stage1, stage2 );