@@ -205,34 +205,31 @@ public void testClientGetTasksAllQueryParameters() throws Exception {
205205 assertThat (result .getNext (), is (notNullValue ()));
206206 assertThat (result .getResults ().length , is (notNullValue ()));
207207 }
208- /** Test to check if task list is reversed when enabled */
208+
209209 @ Test
210210 public void testGetTasksInReverse () {
211211 String indexUid = "tasksOnReverseOrder" ;
212212 Date currentTime = Date .from (Instant .now ());
213213 TestData <Movie > testData = this .getTestData (MOVIES_INDEX , Movie .class );
214-
215- TaskInfo taskA = client .index (indexUid ).addDocuments (testData .getRaw ());
216- TaskInfo taskB = client .index (indexUid ).addDocuments (testData .getRaw ());
217-
218- client .waitForTask (taskA .getTaskUid ());
219- client .waitForTask (taskB .getTaskUid ());
220-
221- Task [] defaultTaskList =
222- client .getTasks (new TasksQuery ().setAfterEnqueuedAt (currentTime )).getResults ();
223- Task [] reversedTaskList =
224- client .getTasks (new TasksQuery ().setAfterEnqueuedAt (currentTime ).setReverse (true ))
225- .getResults ();
226-
227- List <Integer > originalTaskOrder =
228- Arrays .stream (defaultTaskList ).map (Task ::getUid ).collect (Collectors .toList ());
229- List <Integer > reversedTaskOrder =
230- Arrays .stream (reversedTaskList ).map (Task ::getUid ).collect (Collectors .toList ());
231- assertFalse (originalTaskOrder .isEmpty ());
232- assertFalse (reversedTaskOrder .isEmpty ());
214+ TasksQuery query = new TasksQuery ().setAfterEnqueuedAt (currentTime );
215+ TasksQuery queryWithReverseFlag =
216+ new TasksQuery ().setAfterEnqueuedAt (currentTime ).setReverse (true );
217+
218+ client .index (indexUid ).addDocuments (testData .getRaw ());
219+ client .waitForTask (client .index (indexUid ).addDocuments (testData .getRaw ()).getTaskUid ());
220+ List <Integer > tasks =
221+ Arrays .stream (client .getTasks (query ).getResults ())
222+ .map (Task ::getUid )
223+ .collect (Collectors .toList ());
224+ List <Integer > reversedTasks =
225+ Arrays .stream (client .getTasks (queryWithReverseFlag ).getResults ())
226+ .map (Task ::getUid )
227+ .collect (Collectors .toList ());
228+
229+ assertFalse (tasks .isEmpty ());
233230 assertIterableEquals (
234- originalTaskOrder ,
235- reversedTaskOrder .stream ()
231+ tasks ,
232+ reversedTasks .stream ()
236233 .sorted (Collections .reverseOrder ())
237234 .collect (Collectors .toList ()),
238235 "The lists are not reversed versions of each other" );
0 commit comments