package au.gov.amsa.ais.rx;

import java.io.File;

import rx.schedulers.Schedulers;

public class SorterMain {

	public static void main(String[] args) throws InterruptedException {
		String output = System.getProperty("output", "target/output");
		output = "/media/an/binary-fixes-2012/temp";
		long sampleSeconds = Long.parseLong(System.getProperty("sampleSeconds", "0"));
		Streams.sortBinaryFixFilesByTime(new File(output), sampleSeconds, Schedulers.immediate())
		        .count().toBlocking().single();
	}

}

@@ -105,17 +105,20 @@
 Main %7B%0A%0A
-%09
+    
 public s
@@ -178,18 +178,24 @@
 ption %7B%0A
-%09%09
+        
 String o
@@ -249,18 +249,27 @@
 tput%22);%0A
-%09%09
+        // 
 output =
@@ -305,18 +305,24 @@
 /temp%22;%0A
-%09%09
+        
 long sam
@@ -392,18 +392,24 @@
  %220%22));%0A
-%09%09
+        
 Streams.
@@ -494,10 +494,16 @@
 ())%0A
-%09%09
+        
     
@@ -542,9 +542,12 @@
 ();%0A
-%09
+    
 %7D%0A%0A%7D

make SorterMain accessible via pom