From c244ea7c6b5610997ebed45a11ba180772c0096a Mon Sep 17 00:00:00 2001 From: oborkovskyi Date: Mon, 21 Dec 2015 13:52:26 +0200 Subject: [PATCH] Splitted test to grouped by methods used tests. --- .../baeldung/guava/FluentIterableTest.java | 80 ++++++++ .../baeldung/guava/GuavaMiscUtilsTest.java | 41 ++++ .../java/com/baeldung/guava/GuavaTest.java | 177 ------------------ .../com/baeldung/guava/MoreExecutorsTest.java | 51 +++++ .../com/baeldung/guava/MoreObjectsTest.java | 33 ++++ 5 files changed, 205 insertions(+), 177 deletions(-) create mode 100644 guava18/src/test/java/com/baeldung/guava/FluentIterableTest.java create mode 100644 guava18/src/test/java/com/baeldung/guava/GuavaMiscUtilsTest.java delete mode 100644 guava18/src/test/java/com/baeldung/guava/GuavaTest.java create mode 100644 guava18/src/test/java/com/baeldung/guava/MoreExecutorsTest.java create mode 100644 guava18/src/test/java/com/baeldung/guava/MoreObjectsTest.java diff --git a/guava18/src/test/java/com/baeldung/guava/FluentIterableTest.java b/guava18/src/test/java/com/baeldung/guava/FluentIterableTest.java new file mode 100644 index 0000000000..82552fca8f --- /dev/null +++ b/guava18/src/test/java/com/baeldung/guava/FluentIterableTest.java @@ -0,0 +1,80 @@ +package com.baeldung.guava; + +import com.baeldung.guava.entity.User; +import com.google.common.base.Functions; +import com.google.common.base.Joiner; +import com.google.common.base.Predicate; +import com.google.common.collect.FluentIterable; +import org.junit.Assert; +import org.junit.Test; + +import java.util.ArrayList; +import java.util.List; + +import static org.hamcrest.CoreMatchers.equalTo; + +public class FluentIterableTest { + + private static final int ADULT_AGE = 18; + + @Test + public void whenFilteringByAge_shouldFilterOnlyAdultUsers() throws Exception { + List users = new ArrayList<>(); + users.add(new User(1L, "John", 45)); + users.add(new User(2L, "Michael", 27)); + users.add(new User(3L, "Max", 16)); + users.add(new User(4L, "Bob", 10)); + users.add(new User(5L, "Bill", 65)); + + Predicate byAge = input -> input.getAge() > ADULT_AGE; + + List results = FluentIterable.from(users) + .filter(byAge) + .transform(Functions.toStringFunction()) + .toList(); + + Assert.assertThat(results.size(), equalTo(3)); + } + + @Test + public void whenCreatingFluentIterableFromArray_shouldContainAllUsers() throws Exception { + User[] usersArray = {new User(1L, "John", 45), new User(2L, "Max", 15)}; + FluentIterable users = FluentIterable.of(usersArray); + + Assert.assertThat(users.size(), equalTo(2)); + } + + @Test + public void whenAppendingElementsToFluentIterable_shouldContainAllUsers() throws Exception { + User[] usersArray = {new User(1L, "John", 45), new User(2L, "Max", 15)}; + + FluentIterable users = FluentIterable.of(usersArray).append( + new User(3L, "Bob", 23), + new User(4L, "Bill", 17) + ); + + Assert.assertThat(users.size(), equalTo(4)); + } + + @Test + public void whenAppendingListToFluentIterable_shouldContainAllUsers() throws Exception { + User[] usersArray = {new User(1L, "John", 45), new User(2L, "Max", 15)}; + + List usersList = new ArrayList<>(); + usersList.add(new User(3L, "David", 32)); + + FluentIterable users = FluentIterable.of(usersArray).append(usersList); + + Assert.assertThat(users.size(), equalTo(3)); + } + + @Test + public void whenJoiningFluentIterableElements_shouldOutputAllUsers() throws Exception { + User[] usersArray = {new User(1L, "John", 45), new User(2L, "Max", 15)}; + + FluentIterable users = FluentIterable.of(usersArray); + + Assert.assertThat(users.join(Joiner.on("; ")), + equalTo("User{id=1, name=John, age=45}; User{id=2, name=Max, age=15}")); + } +} \ No newline at end of file diff --git a/guava18/src/test/java/com/baeldung/guava/GuavaMiscUtilsTest.java b/guava18/src/test/java/com/baeldung/guava/GuavaMiscUtilsTest.java new file mode 100644 index 0000000000..db82ea6da8 --- /dev/null +++ b/guava18/src/test/java/com/baeldung/guava/GuavaMiscUtilsTest.java @@ -0,0 +1,41 @@ +package com.baeldung.guava; + +import com.google.common.hash.HashCode; +import com.google.common.hash.Hashing; +import com.google.common.net.InetAddresses; +import org.junit.Assert; +import org.junit.Test; + +import java.net.InetAddress; +import java.util.concurrent.ConcurrentHashMap; + +import static org.hamcrest.CoreMatchers.equalTo; + +public class GuavaMiscUtilsTest { + @Test + public void whenHashingData_shouldReturnCorrectHashCode() throws Exception { + int receivedData = 123; + + HashCode hashCode = Hashing.crc32c().hashInt(receivedData); + Assert.assertThat(hashCode.toString(), equalTo("495be649")); + } + + @Test + public void whenDecrementingIpAddress_shouldReturnOneLessIpAddress() throws Exception { + InetAddress address = InetAddress.getByName("127.0.0.5"); + InetAddress decrementedAddress = InetAddresses.decrement(address); + + Assert.assertThat(decrementedAddress.toString(), equalTo("/127.0.0.4")); + } + + @Test + public void whenExecutingRunnableInThread_shouldLogThreadExecution() throws Exception { + ConcurrentHashMap threadExecutions = new ConcurrentHashMap<>(); + Runnable logThreadRun = () -> threadExecutions.put(Thread.currentThread().getName(), true); + + Thread t = new Thread(logThreadRun); + t.run(); + + Assert.assertTrue(threadExecutions.get("main")); + } +} diff --git a/guava18/src/test/java/com/baeldung/guava/GuavaTest.java b/guava18/src/test/java/com/baeldung/guava/GuavaTest.java deleted file mode 100644 index 5d1d1c074a..0000000000 --- a/guava18/src/test/java/com/baeldung/guava/GuavaTest.java +++ /dev/null @@ -1,177 +0,0 @@ -import com.baeldung.guava.entity.Administrator; -import com.baeldung.guava.entity.Player; -import com.baeldung.guava.entity.User; -import com.google.common.base.Functions; -import com.google.common.base.Joiner; -import com.google.common.base.Predicate; -import com.google.common.collect.FluentIterable; -import com.google.common.hash.HashCode; -import com.google.common.hash.Hashing; -import com.google.common.net.InetAddresses; -import com.google.common.util.concurrent.ListeningExecutorService; -import com.google.common.util.concurrent.MoreExecutors; -import org.junit.Assert; -import org.junit.Test; - -import java.net.InetAddress; -import java.util.ArrayList; -import java.util.List; -import java.util.concurrent.*; - -import static org.hamcrest.CoreMatchers.equalTo; - -public class GuavaTest { - - private static final int ADULT_AGE = 18; - - @Test - public void whenToString_shouldIncludeAllFields() throws Exception { - User user = new User(12L, "John Doe", 25); - - Assert.assertThat(user.toString(), equalTo("User{id=12, name=John Doe, age=25}")); - } - - @Test - public void whenPlayerToString_shouldCallParentToString() throws Exception { - User user = new Player(12L, "John Doe", 25); - - Assert.assertThat(user.toString(), equalTo("User{id=12, name=John Doe, age=25}")); - } - - @Test - public void whenAdministratorToString_shouldExecuteAdministratorToString() throws Exception { - User user = new Administrator(12L, "John Doe", 25); - - Assert.assertThat(user.toString(), equalTo("Administrator{id=12, name=John Doe, age=25}")); - } - - @Test - public void whenFilteringByAge_shouldFilterOnlyAdultUsers() throws Exception { - List users = new ArrayList<>(); - users.add(new User(1L, "John", 45)); - users.add(new User(2L, "Michael", 27)); - users.add(new User(3L, "Max", 16)); - users.add(new User(4L, "Bob", 10)); - users.add(new User(5L, "Bill", 65)); - - Predicate byAge = input -> input.getAge() > ADULT_AGE; - - List results = FluentIterable.from(users) - .filter(byAge) - .transform(Functions.toStringFunction()) - .toList(); - - Assert.assertThat(results.size(), equalTo(3)); - } - - @Test - public void whenCreatingFluentIterableFromArray_shouldContainAllUsers() throws Exception { - User[] usersArray = {new User(1L, "John", 45), new User(2L, "Max", 15)} ; - FluentIterable users = FluentIterable.of(usersArray); - - Assert.assertThat(users.size(), equalTo(2)); - } - - @Test - public void whenAppendingElementsToFluentIterable_shouldContainAllUsers() throws Exception { - User[] usersArray = {new User(1L, "John", 45), new User(2L, "Max", 15)}; - - FluentIterable users = FluentIterable.of(usersArray).append( - new User(3L, "Bob", 23), - new User(4L, "Bill", 17) - ); - - Assert.assertThat(users.size(), equalTo(4)); - } - - @Test - public void whenAppendingListToFluentIterable_shouldContainAllUsers() throws Exception { - User[] usersArray = {new User(1L, "John", 45), new User(2L, "Max", 15)}; - - List usersList = new ArrayList<>(); - usersList.add(new User(3L, "David", 32)); - - FluentIterable users = FluentIterable.of(usersArray).append(usersList); - - Assert.assertThat(users.size(), equalTo(3)); - } - - @Test - public void whenJoiningFluentIterableElements_shouldOutputAllUsers() throws Exception { - User[] usersArray = {new User(1L, "John", 45), new User(2L, "Max", 15)}; - - FluentIterable users = FluentIterable.of(usersArray); - - Assert.assertThat(users.join(Joiner.on("; ")), - equalTo("User{id=1, name=John, age=45}; User{id=2, name=Max, age=15}")); - } - - @Test - public void whenHashingData_shouldReturnCorrectHashCode() throws Exception { - int receivedData = 123; - - HashCode hashCode = Hashing.crc32c().hashInt(receivedData); - Assert.assertThat(hashCode.toString(), equalTo("495be649")); - } - - @Test - public void whenDecrementingIpAddress_shouldReturnOneLessIpAddress() throws Exception { - InetAddress address = InetAddress.getByName("127.0.0.5"); - InetAddress decrementedAddress = InetAddresses.decrement(address); - - Assert.assertThat(decrementedAddress.toString(), equalTo("/127.0.0.4")); - - } - - @Test - public void whenExecutingRunnableInThread_shouldLogThreadExecution() throws Exception { - ConcurrentHashMap threadExecutions = new ConcurrentHashMap<>(); - Runnable logThreadRun = () -> threadExecutions.put(Thread.currentThread().getName(), true); - - Thread t = new Thread(logThreadRun); - t.run(); - - Assert.assertTrue(threadExecutions.get("main")); - } - - @Test - public void whenExecutingRunnableInThreadPool_shouldLogAllThreadsExecutions() throws Exception { - ConcurrentHashMap threadExecutions = new ConcurrentHashMap<>(); - - Runnable logThreadRun= () -> threadExecutions.put(Thread.currentThread().getName(), true); - - ExecutorService executorService = Executors.newFixedThreadPool(2); - executorService.submit(logThreadRun); - executorService.submit(logThreadRun); - executorService.shutdown(); - - executorService.awaitTermination(100, TimeUnit.MILLISECONDS); - - Assert.assertTrue(threadExecutions.get("pool-1-thread-1")); - Assert.assertTrue(threadExecutions.get("pool-1-thread-2")); - } - - @Test - public void whenExecutingRunnableInDirectExecutor_shouldLogThreadExecution() throws Exception { - ConcurrentHashMap threadExecutions = new ConcurrentHashMap<>(); - - Runnable logThreadRun= () -> threadExecutions.put(Thread.currentThread().getName(), true); - - Executor executor = MoreExecutors.directExecutor(); - executor.execute(logThreadRun); - - Assert.assertTrue(threadExecutions.get("main")); - } - - @Test - public void whenExecutingRunnableInListeningExecutor_shouldLogThreadExecution() throws Exception { - ConcurrentHashMap threadExecutions = new ConcurrentHashMap<>(); - - Runnable logThreadRun = () -> threadExecutions.put(Thread.currentThread().getName(), true); - - ListeningExecutorService executor = MoreExecutors.newDirectExecutorService(); - executor.execute(logThreadRun); - - Assert.assertTrue(threadExecutions.get("main")); - } -} \ No newline at end of file diff --git a/guava18/src/test/java/com/baeldung/guava/MoreExecutorsTest.java b/guava18/src/test/java/com/baeldung/guava/MoreExecutorsTest.java new file mode 100644 index 0000000000..ec173499f1 --- /dev/null +++ b/guava18/src/test/java/com/baeldung/guava/MoreExecutorsTest.java @@ -0,0 +1,51 @@ +package com.baeldung.guava; + +import com.google.common.util.concurrent.ListeningExecutorService; +import com.google.common.util.concurrent.MoreExecutors; +import org.junit.Assert; +import org.junit.Test; + +import java.util.concurrent.*; + +public class MoreExecutorsTest { + @Test + public void whenExecutingRunnableInThreadPool_shouldLogAllThreadsExecutions() throws Exception { + ConcurrentHashMap threadExecutions = new ConcurrentHashMap<>(); + + Runnable logThreadRun = () -> threadExecutions.put(Thread.currentThread().getName(), true); + + ExecutorService executorService = Executors.newFixedThreadPool(2); + executorService.submit(logThreadRun); + executorService.submit(logThreadRun); + executorService.shutdown(); + + executorService.awaitTermination(100, TimeUnit.MILLISECONDS); + + Assert.assertTrue(threadExecutions.get("pool-1-thread-1")); + Assert.assertTrue(threadExecutions.get("pool-1-thread-2")); + } + + @Test + public void whenExecutingRunnableInDirectExecutor_shouldLogThreadExecution() throws Exception { + ConcurrentHashMap threadExecutions = new ConcurrentHashMap<>(); + + Runnable logThreadRun = () -> threadExecutions.put(Thread.currentThread().getName(), true); + + Executor executor = MoreExecutors.directExecutor(); + executor.execute(logThreadRun); + + Assert.assertTrue(threadExecutions.get("main")); + } + + @Test + public void whenExecutingRunnableInListeningExecutor_shouldLogThreadExecution() throws Exception { + ConcurrentHashMap threadExecutions = new ConcurrentHashMap<>(); + + Runnable logThreadRun = () -> threadExecutions.put(Thread.currentThread().getName(), true); + + ListeningExecutorService executor = MoreExecutors.newDirectExecutorService(); + executor.execute(logThreadRun); + + Assert.assertTrue(threadExecutions.get("main")); + } +} diff --git a/guava18/src/test/java/com/baeldung/guava/MoreObjectsTest.java b/guava18/src/test/java/com/baeldung/guava/MoreObjectsTest.java new file mode 100644 index 0000000000..5e46b5aba9 --- /dev/null +++ b/guava18/src/test/java/com/baeldung/guava/MoreObjectsTest.java @@ -0,0 +1,33 @@ +package com.baeldung.guava; + +import com.baeldung.guava.entity.Administrator; +import com.baeldung.guava.entity.Player; +import com.baeldung.guava.entity.User; +import org.junit.Assert; +import org.junit.Test; + +import static org.hamcrest.CoreMatchers.equalTo; + +public class MoreObjectsTest { + + @Test + public void whenToString_shouldIncludeAllFields() throws Exception { + User user = new User(12L, "John Doe", 25); + + Assert.assertThat(user.toString(), equalTo("User{id=12, name=John Doe, age=25}")); + } + + @Test + public void whenPlayerToString_shouldCallParentToString() throws Exception { + User user = new Player(12L, "John Doe", 25); + + Assert.assertThat(user.toString(), equalTo("User{id=12, name=John Doe, age=25}")); + } + + @Test + public void whenAdministratorToString_shouldExecuteAdministratorToString() throws Exception { + User user = new Administrator(12L, "John Doe", 25); + + Assert.assertThat(user.toString(), equalTo("Administrator{id=12, name=John Doe, age=25}")); + } +}