Minor tweaks to improve consistency

See #294

Author: fsteeg

metafacture-flowcontrol/src/main/java/org/metafacture/flowcontrol/ObjectPipeDecoupler.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2013, 2014 Deutsche Nationalbibliothek
+ * Copyright 2013-2019 Deutsche Nationalbibliothek and others
  *
  * Licensed under the Apache License, Version 2.0 the "License";
  * you may not use this file except in compliance with the License.
@@ -33,6 +33,7 @@
  * @param <T> Object type
  *
  * @author Markus Micheal Geipel
+ * @author Pascal Christoph (dr0i)
  */
 @In(Object.class)
 @Out(Object.class)

metafacture-flowcontrol/src/main/java/org/metafacture/flowcontrol/ObjectThreader.java

@@ -1,4 +1,4 @@
-/* Copyright 2019 hbz, Pascal Christoph. 
+/* Copyright 2019 Pascal Christoph, hbz.
  * 
  * Licensed under the Apache License, Version 2.0 the "License";
  * you may not use this file except in compliance with the License.
@@ -34,12 +34,12 @@
  * 
  * @param <T> Object type
  *
- * @author Pascal Christoph(dr0i)
+ * @author Pascal Christoph (dr0i)
  * 
  */
 @In(Object.class)
 @Out(Object.class)
-@Description("incoming objects are distributed to the added receivers, running in their own threads")
+@Description("Incoming objects are distributed to the added receivers, running in their own threads.")
 @FluxCommand("thread-object-tee")
 public class ObjectThreader<T> extends DefaultTee<ObjectReceiver<T>> implements ObjectPipe<T, ObjectReceiver<T>> {
 
@@ -49,10 +49,11 @@ public class ObjectThreader<T> extends DefaultTee<ObjectReceiver<T>> implements
     @Override
     public void process(final T obj) {
         getReceivers().get(objectNumber).process(obj);
-        if (objectNumber == getReceivers().size() - 1)
+        if (objectNumber == getReceivers().size() - 1) {
             objectNumber = 0;
-        else
+        } else {
             objectNumber++;
+        }
     }
 
     @Override

metafacture-flowcontrol/src/test/java/org/metafacture/flowcontrol/ObjectThreaderTest.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2019 hbz
+ * Copyright 2019 Pascal Christoph, hbz.
  *
  * Licensed under the Apache License, Version 2.0 the "License";
  * you may not use this file except in compliance with the License.
@@ -15,6 +15,8 @@
  */
 package org.metafacture.flowcontrol;
 
+import static org.assertj.core.api.Assertions.assertThat;
+
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.atMost;
 import static org.mockito.Mockito.atLeast;
@@ -31,7 +33,7 @@
  * Tests for class {@link ObjectThreader} (which itself uses
  * {@link org.metafacture.flowcontrol.ObjectPipeDecoupler} to thread receivers).
  *
- * @author Pascal Christoph(dr0i)
+ * @author Pascal Christoph (dr0i)
  *
  */
 public final class ObjectThreaderTest {
@@ -59,7 +61,7 @@ public void shouldSplitAllObjectsToAllThreadedDownStreamReceivers() throws Inter
 		objectThreader.process("a");
 		objectThreader.process("c");
 		// check if two more threads were indeed created
-		assert (Thread.getAllStackTraces().keySet().size() - ACTIVE_THREADS_AT_BEGINNING == 2);
+		assertThat(Thread.getAllStackTraces().keySet().size() - ACTIVE_THREADS_AT_BEGINNING).isEqualTo(2);
 		objectThreader.closeStream();
 		// verify thread 1
 		verify(receiverThread1, atLeast(2)).process("a");