Removed Trailing whiespaces and corrected the indentation
@@ -21,7 +21,6 @@ public class CharacterUnitTest {
.expectComplete()
.verify();
}
-
@Test
public void whenCreatingCharactersWithMultipleThreads_thenSequenceIsProducedAsynchronously() throws InterruptedException {
CharacterGenerator characterGenerator = new CharacterGenerator();
@@ -35,14 +34,10 @@ public class CharacterUnitTest {
.block();
CharacterCreator characterCreator = new CharacterCreator();
-
Thread producerThread1 = new Thread(
- () -> characterCreator.consumer.accept(sequence1)
- );
+ () -> characterCreator.consumer.accept(sequence1));
Thread producerThread2 = new Thread(
- () -> characterCreator.consumer.accept(sequence2)
- );
-
+ () -> characterCreator.consumer.accept(sequence2));
List<Character> consolidated = new ArrayList<>();
characterCreator.createCharacterSequence().subscribe(consolidated::add);
