Normalise line endings

Author: cboehme

src/test/java/org/culturegraph/mf/stream/pipe/StreamBufferTest.java

@@ -13,26 +13,26 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
-
+package org.culturegraph.mf.stream.pipe;
+
 import static org.junit.Assert.fail;
 
 import org.culturegraph.mf.exceptions.FormatException;
 import org.culturegraph.mf.framework.StreamReceiver;
 import org.culturegraph.mf.stream.sink.EventList;
 import org.culturegraph.mf.stream.sink.StreamValidator;
 import org.junit.Test;
-
-
-/**
- * Tests {@link StreamBuffer}.
- * 
+
+
+/**
+ * Tests {@link StreamBuffer}.
+ * 
  * @author Markus Michael Geipel
- * @author Christoph Böhme
- */
-public final class StreamBufferTest {
-
-	@Test
+ * @author Christoph Böhme
+ */
+public final class StreamBufferTest {
+
+	@Test
 	public void testCorrectBuffering(){
 		final EventList list = new EventList();
 		execTestEvents(list);
@@ -47,7 +47,7 @@ public void testCorrectBuffering(){
 			buffer.closeStream();
 		} catch (FormatException e) {
 			fail("Error during replay: " + e);
-		}
+		}
 	}
 
 	private void execTestEvents(final StreamReceiver receiver) {
@@ -62,5 +62,5 @@ private void execTestEvents(final StreamReceiver receiver) {
 		receiver.literal("l3", "value4");
 		receiver.endRecord();
 	}
-	
-}
+	
+}

src/test/java/org/culturegraph/mf/stream/pipe/StreamLoggerTest.java

@@ -13,27 +13,27 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
-
+package org.culturegraph.mf.stream.pipe;
+
 import static org.junit.Assert.fail;
 
 import org.culturegraph.mf.exceptions.FormatException;
 import org.culturegraph.mf.framework.StreamReceiver;
 import org.culturegraph.mf.stream.sink.EventList;
 import org.culturegraph.mf.stream.sink.StreamValidator;
 import org.junit.Test;
-
-
-/**
- * Tests if {@link StreamLogger} is correctly piping all events.
- * 
- * @author Markus Michael Geipel, Christoph Böhme
- */
-
-public final class StreamLoggerTest {
-
-	@Test
-	public void testCorrectPipeFunction() {
+
+
+/**
+ * Tests if {@link StreamLogger} is correctly piping all events.
+ * 
+ * @author Markus Michael Geipel, Christoph Böhme
+ */
+
+public final class StreamLoggerTest {
+
+	@Test
+	public void testCorrectPipeFunction() {
 		final EventList list = new EventList();
 		execTestEvents(list);
 
@@ -47,7 +47,7 @@ public void testCorrectPipeFunction() {
 		} catch (FormatException e) {
 			fail("Logger did not forward data as expected: " + e);
 		}
-
+
 	}
 
 	private void execTestEvents(final StreamReceiver receiver) {
@@ -62,5 +62,5 @@ private void execTestEvents(final StreamReceiver receiver) {
 		receiver.literal("l3", "value4");
 		receiver.endRecord();
 	}
-
-}
+
+}

src/test/java/org/culturegraph/mf/stream/pipe/StreamTeeTest.java

@@ -13,26 +13,26 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
-
+package org.culturegraph.mf.stream.pipe;
+
 import static org.junit.Assert.fail;
 
 import org.culturegraph.mf.exceptions.FormatException;
 import org.culturegraph.mf.framework.StreamReceiver;
 import org.culturegraph.mf.stream.sink.EventList;
 import org.culturegraph.mf.stream.sink.StreamValidator;
 import org.junit.Test;
-
-
-/**
- * Tests if {@link StreamTee} is correctly piping all events.
- * 
- * @author Markus Michael Geipel
- *
- */
-public final class StreamTeeTest {
-	
-	@Test
+
+
+/**
+ * Tests if {@link StreamTee} is correctly piping all events.
+ * 
+ * @author Markus Michael Geipel
+ *
+ */
+public final class StreamTeeTest {
+	
+	@Test
 	public void testCorrectTeeFunction() {
 		final EventList list = new EventList();
 		execTestEvents(list);
@@ -48,7 +48,7 @@ public void testCorrectTeeFunction() {
 			tee.closeStream();
 		} catch (FormatException e) {
 			fail("Tee did not forward data as expected: " + e);
-		}
+		}
 	}
 
 	private void execTestEvents(final StreamReceiver receiver) {
@@ -63,5 +63,5 @@ private void execTestEvents(final StreamReceiver receiver) {
 		receiver.literal("l3", "value4");
 		receiver.endRecord();
 	}
-
-}
+
+}

src/test/java/org/culturegraph/mf/stream/pipe/StreamTimerTest.java

@@ -13,53 +13,53 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe;
-
-import org.culturegraph.mf.framework.DefaultStreamReceiver;
-import org.culturegraph.mf.stream.pipe.ObjectTimer;
-import org.culturegraph.mf.stream.pipe.StreamTimer;
-import org.junit.Test;
-
-
-/**
- * Tests {@link ObjectTimer}.
- * 
- * @author Christoph Böhme
- */
-public final class StreamTimerTest {
-
-	private static final long[] DURATIONS = { 150L, 20L, 30L, 202L };
-	
-	/**
-	 * A module with a slow process method.
-	 */
-	private static final class BenchmarkedModule extends DefaultStreamReceiver {
-		
-		@Override
-		public void literal(final String name, final String value) {
-			final long duration = Long.parseLong(value);
-			try {
-				Thread.sleep(duration);
-			} catch (InterruptedException e) {
-				return;
-			}
-		}
-	}
-	
-	@Test
-	public void testObjectTimer() {
-		final StreamTimer timer = new StreamTimer();
-		final BenchmarkedModule benchmarkedModule = new BenchmarkedModule();
-		
-		timer.setReceiver(benchmarkedModule);
-		
-		for (int i=0; i < DURATIONS.length; ++i) {
-			timer.startRecord(Integer.toString(i));
-			timer.literal("duration", Long.toString(DURATIONS[i]));
-			timer.endRecord();
-		}
-		
-		timer.closeStream();
-	}
-
-}
+package org.culturegraph.mf.stream.pipe;
+
+import org.culturegraph.mf.framework.DefaultStreamReceiver;
+import org.culturegraph.mf.stream.pipe.ObjectTimer;
+import org.culturegraph.mf.stream.pipe.StreamTimer;
+import org.junit.Test;
+
+
+/**
+ * Tests {@link ObjectTimer}.
+ * 
+ * @author Christoph Böhme
+ */
+public final class StreamTimerTest {
+
+	private static final long[] DURATIONS = { 150L, 20L, 30L, 202L };
+	
+	/**
+	 * A module with a slow process method.
+	 */
+	private static final class BenchmarkedModule extends DefaultStreamReceiver {
+		
+		@Override
+		public void literal(final String name, final String value) {
+			final long duration = Long.parseLong(value);
+			try {
+				Thread.sleep(duration);
+			} catch (InterruptedException e) {
+				return;
+			}
+		}
+	}
+	
+	@Test
+	public void testObjectTimer() {
+		final StreamTimer timer = new StreamTimer();
+		final BenchmarkedModule benchmarkedModule = new BenchmarkedModule();
+		
+		timer.setReceiver(benchmarkedModule);
+		
+		for (int i=0; i < DURATIONS.length; ++i) {
+			timer.startRecord(Integer.toString(i));
+			timer.literal("duration", Long.toString(DURATIONS[i]));
+			timer.endRecord();
+		}
+		
+		timer.closeStream();
+	}
+
+}

src/test/java/org/culturegraph/mf/stream/pipe/bib/OreAggregationAdderTest.java

@@ -13,14 +13,14 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.culturegraph.mf.stream.pipe.bib;
-
-import org.culturegraph.mf.test.TestSuite;
-import org.junit.runner.RunWith;
-
-
-/**
- * @author Markus Michael Geipel
- */
-@RunWith(TestSuite.class)
-public final class OreAggregationAdderTest {/*bind to xml test*/}
+package org.culturegraph.mf.stream.pipe.bib;
+
+import org.culturegraph.mf.test.TestSuite;
+import org.junit.runner.RunWith;
+
+
+/**
+ * @author Markus Michael Geipel
+ */
+@RunWith(TestSuite.class)
+public final class OreAggregationAdderTest {/*bind to xml test*/}

src/test/java/org/culturegraph/mf/stream/reader/MultiFormatReaderTest.java

@@ -13,46 +13,46 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.culturegraph.mf.stream.reader;
-
-import org.culturegraph.mf.stream.reader.MultiFormatReader;
-import org.junit.Assert;
-import org.junit.Test;
-
-
-/**
- * Tests {@link MultiFormatReader}
- * @author Markus Michael Geipel
- *
- */
-public final class MultiFormatReaderTest {
-	
-	private static final String PICA = "pica";
-	private static final String MAB2 = "mab2";
-	
-
-	@Test(expected=IllegalStateException.class)
-	public void testMissingFormat(){
-		final MultiFormatReader formatReader = new MultiFormatReader();
-		formatReader.read("gurk");
-	}
-	
-	@Test
-	public void testFormatSwitch(){
-		final MultiFormatReader formatReader = new MultiFormatReader();
-		formatReader.setFormat(PICA);
-		Assert.assertEquals(PICA, formatReader.getFormat());
-		formatReader.setFormat(MAB2);
-		Assert.assertEquals(MAB2, formatReader.getFormat());
-		
-	}
-	
-	@Test(expected=IllegalStateException.class)
-	public void testMissingReceiver(){	
-		final MultiFormatReader formatReader = new MultiFormatReader();
-		formatReader.setFormat(PICA);
-		formatReader.read("hula");
-	}
-	
-
-}
+package org.culturegraph.mf.stream.reader;
+
+import org.culturegraph.mf.stream.reader.MultiFormatReader;
+import org.junit.Assert;
+import org.junit.Test;
+
+
+/**
+ * Tests {@link MultiFormatReader}
+ * @author Markus Michael Geipel
+ *
+ */
+public final class MultiFormatReaderTest {
+	
+	private static final String PICA = "pica";
+	private static final String MAB2 = "mab2";
+	
+
+	@Test(expected=IllegalStateException.class)
+	public void testMissingFormat(){
+		final MultiFormatReader formatReader = new MultiFormatReader();
+		formatReader.read("gurk");
+	}
+	
+	@Test
+	public void testFormatSwitch(){
+		final MultiFormatReader formatReader = new MultiFormatReader();
+		formatReader.setFormat(PICA);
+		Assert.assertEquals(PICA, formatReader.getFormat());
+		formatReader.setFormat(MAB2);
+		Assert.assertEquals(MAB2, formatReader.getFormat());
+		
+	}
+	
+	@Test(expected=IllegalStateException.class)
+	public void testMissingReceiver(){	
+		final MultiFormatReader formatReader = new MultiFormatReader();
+		formatReader.setFormat(PICA);
+		formatReader.read("hula");
+	}
+	
+
+}