fixed #58

Author: mgeipel

examples/misc/multiple-flows/data.txt

@@ -0,0 +1,4 @@
+A
+B
+C
+D

examples/misc/multiple-flows/multiple-flows.flux

@@ -0,0 +1,15 @@
+default data = FLUX_DIR + "data.txt";
+default temp_file = "data.tmp";
+
+//first flow
+data|
+open-file|
+as-lines|
+write(temp_file);
+
+//second flow
+temp_file|
+open-file|
+as-lines|
+write("stdout");
+

examples/morph/morph-marc21.flux

@@ -7,4 +7,3 @@ decode-marc21|
 morph(FLUX_DIR + "morph-marc21.xml")|
 encode("literals")|
 write("stdout");
-//write("file://???");

src/main/java/org/culturegraph/mf/Flux.java

@@ -95,8 +95,10 @@ public boolean accept(final File dir, final String name) {
 			}
 
 			// run parser and builder
-			FluxCompiler.compile(ResourceUtil.getStream(fluxFile), vars).start();
-			//flow.start();
+			final List<Flow> flows = FluxCompiler.compile(ResourceUtil.getStream(fluxFile), vars);
+			for (Flow flow : flows) {
+				flow.start();
+			}
 		}
 	}