Skip to content

Commit 753e586

Browse files
committed
async tests fixes
1 parent 809ddd6 commit 753e586

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

test-functional/src/test/java/com/arangodb/ArangoCollectionAsyncTest.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3057,7 +3057,7 @@ void deleteDocumentsByDocumentOne(ArangoCollectionAsync collection) throws Execu
30573057
@MethodSource("asyncCols")
30583058
void deleteDocumentsEmpty(ArangoCollectionAsync collection) throws ExecutionException, InterruptedException {
30593059
final Collection<BaseDocument> values = new ArrayList<>();
3060-
collection.insertDocuments(values);
3060+
collection.insertDocuments(values).get();
30613061
final Collection<String> keys = new ArrayList<>();
30623062
final MultiDocumentEntity<?> deleteResult = collection.deleteDocuments(keys).get();
30633063
assertThat(deleteResult).isNotNull();
@@ -3069,7 +3069,7 @@ void deleteDocumentsEmpty(ArangoCollectionAsync collection) throws ExecutionExce
30693069
@MethodSource("asyncCols")
30703070
void deleteDocumentsByKeyNotExisting(ArangoCollectionAsync collection) throws ExecutionException, InterruptedException {
30713071
final Collection<BaseDocument> values = new ArrayList<>();
3072-
collection.insertDocuments(values);
3072+
collection.insertDocuments(values).get();
30733073
final Collection<String> keys = Arrays.asList(rnd(), rnd());
30743074

30753075
final MultiDocumentEntity<?> deleteResult = collection.deleteDocuments(keys).get();
@@ -3170,7 +3170,7 @@ void updateDocumentsWithoutKey(ArangoCollectionAsync collection) throws Executio
31703170
{
31713171
values.add(new BaseDocument("1"));
31723172
}
3173-
collection.insertDocuments(values);
3173+
collection.insertDocuments(values).get();
31743174
final Collection<BaseDocument> updatedValues = new ArrayList<>();
31753175
for (final BaseDocument i : values) {
31763176
i.addAttribute("a", "test");
@@ -3188,7 +3188,7 @@ void updateDocumentsJson(ArangoCollectionAsync collection) throws ExecutionExcep
31883188
final Collection<RawJson> values = new ArrayList<>();
31893189
values.add(RawJson.of("{\"_key\":\"1\"}"));
31903190
values.add(RawJson.of("{\"_key\":\"2\"}"));
3191-
collection.insertDocuments(values);
3191+
collection.insertDocuments(values).get();
31923192

31933193
final Collection<RawJson> updatedValues = new ArrayList<>();
31943194
updatedValues.add(RawJson.of("{\"_key\":\"1\", \"foo\":\"bar\"}"));
@@ -3263,7 +3263,7 @@ void replaceDocumentsOne(ArangoCollectionAsync collection) throws ExecutionExcep
32633263
e.setKey("1");
32643264
values.add(e);
32653265
}
3266-
collection.insertDocuments(values);
3266+
collection.insertDocuments(values).get();
32673267
final Collection<BaseDocument> updatedValues = new ArrayList<>();
32683268
final BaseDocument first = values.iterator().next();
32693269
first.addAttribute("a", "test");
@@ -3321,7 +3321,7 @@ void replaceDocumentsJson(ArangoCollectionAsync collection) throws ExecutionExce
33213321
@MethodSource("asyncCols")
33223322
void replaceDocumentsRawData(ArangoCollectionAsync collection) throws ExecutionException, InterruptedException {
33233323
final RawData values = RawJson.of("[{\"_key\":\"1\"}, {\"_key\":\"2\"}]");
3324-
collection.insertDocuments(values);
3324+
collection.insertDocuments(values).get();
33253325

33263326
final RawData updatedValues = RawJson.of("[{\"_key\":\"1\", \"foo\":\"bar\"}, {\"_key\":\"2\", " +
33273327
"\"foo\":\"bar\"}]");

0 commit comments

Comments
 (0)