Initial commit of Java 8 Stream tests.

src/test/java/org/gitlab4j/api/TestStreams.java

+package org.gitlab4j.api;
+
+import static java.util.Comparator.comparing;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.when;
+import static org.mockito.MockitoAnnotations.initMocks;
+
+import static java.util.stream.Collectors.toList;
+
+import java.util.List;
+import java.util.stream.Stream;
+
+import javax.ws.rs.core.MultivaluedMap;
+
+import org.gitlab4j.api.models.User;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Captor;
+import org.mockito.Mock;
+import org.mockito.Mockito;
+import org.mockito.Spy;
+
+public class TestStreams implements Constants {
+
+    @Mock private GitLabApi gitLabApi;
+    @Mock private GitLabApiClient gitLabApiClient;
+    @Spy private FakeResponse response;
+    @Captor private ArgumentCaptor<MultivaluedMap<String, String>> attributeCaptor;
+
+    static private List<User> sortedUsers;
+
+    @BeforeClass
+    public static void setupClass() throws Exception {
+        // Get a list of users sorted by username
+        sortedUsers = JsonUtils.unmarshalResourceList(User.class, "user-list.json");
+        sortedUsers.sort(comparing(User::getUsername));
+    }
+
+    @Before
+    public void setup() throws Exception {
+        initMocks(this);
+        response.init(User.class, null, "user-list.json");
+        when(gitLabApi.getApiClient()).thenReturn(gitLabApiClient);
+        when(gitLabApiClient.validateSecretToken(any())).thenReturn(true);
+        when(gitLabApiClient.get(attributeCaptor.capture(), Mockito.<Object>any())).thenReturn(response);
+    }
+
+    @Test
+    public void testStream() throws Exception {
+
+        Stream<User> stream = new UserApi(gitLabApi).getUsersStream();
+        assertNotNull(stream);
+
+        List<User> users = stream.sorted(comparing(User::getUsername)).collect(toList());
+        assertNotNull(users);
+
+        assertEquals(users.size(), sortedUsers.size());
+
+        for (int i = 0; i < users.size(); i++) {
+            assertEquals(users.get(i).getId(), sortedUsers.get(i).getId());
+            assertEquals(users.get(i).getUsername(), sortedUsers.get(i).getUsername());
+        }
+    }
+
+    @Test
+    public void testParallelStream() throws Exception {
+
+        Stream<User> stream = new UserApi(gitLabApi).getUsersStream();
+        assertNotNull(stream);
+
+        List<User> users = stream.parallel().sorted(comparing(User::getUsername)).collect(toList());
+        assertNotNull(users);
+
+        assertEquals(users.size(), sortedUsers.size());
+
+        for (int i = 0; i < users.size(); i++) {
+            assertEquals(users.get(i).getId(), sortedUsers.get(i).getId());
+            assertEquals(users.get(i).getUsername(), sortedUsers.get(i).getUsername());
+        }
+    }
+}