Fix tests

Author: mpv1989

src/test/java/com/arangodb/ArangoCollectionTest.java

@@ -948,7 +948,7 @@ public void createFulltextIndex() throws InterruptedException, ExecutionExceptio
 	public void getIndexes() throws InterruptedException, ExecutionException {
 		final Collection<String> fields = new ArrayList<>();
 		fields.add("a");
-		db.collection(COLLECTION_NAME).createHashIndex(fields, null);
+		db.collection(COLLECTION_NAME).createHashIndex(fields, null).get();
 		final CompletableFuture<Collection<IndexEntity>> f = db.collection(COLLECTION_NAME).getIndexes();
 		assertThat(f, is(notNullValue()));
 		f.whenComplete((indexes, ex) -> {

src/test/java/com/arangodb/ArangoDatabaseTest.java

@@ -135,7 +135,7 @@ public void createCollectionWithReplicationFactor() throws InterruptedException,
 			assertThat(result.getId(), is(notNullValue()));
 			assertThat(db.collection(COLLECTION_NAME).getProperties().get().getReplicationFactor(), is(2));
 		} finally {
-			db.collection(COLLECTION_NAME).drop();
+			db.collection(COLLECTION_NAME).drop().get();
 		}
 	}
 
@@ -151,7 +151,7 @@ public void createCollectionWithNumberOfShards() throws InterruptedException, Ex
 			assertThat(result.getId(), is(notNullValue()));
 			assertThat(db.collection(COLLECTION_NAME).getProperties().get().getNumberOfShards(), is(2));
 		} finally {
-			db.collection(COLLECTION_NAME).drop();
+			db.collection(COLLECTION_NAME).drop().get();
 		}
 	}
 
@@ -170,7 +170,7 @@ public void createCollectionWithNumberOfShardsAndShardKey() throws InterruptedEx
 			assertThat(properties.getNumberOfShards(), is(2));
 			assertThat(properties.getShardKeys().size(), is(1));
 		} finally {
-			db.collection(COLLECTION_NAME).drop();
+			db.collection(COLLECTION_NAME).drop().get();
 		}
 	}
 
@@ -188,7 +188,7 @@ public void createCollectionWithNumberOfShardsAndShardKeys() throws InterruptedE
 			assertThat(properties.getNumberOfShards(), is(2));
 			assertThat(properties.getShardKeys().size(), is(2));
 		} finally {
-			db.collection(COLLECTION_NAME).drop();
+			db.collection(COLLECTION_NAME).drop().get();
 		}
 	}
 
@@ -783,7 +783,7 @@ public void getAndClearSlowQueries() throws InterruptedException, ExecutionExcep
 			final QueryEntity queryEntity = slowQueries.iterator().next();
 			assertThat(queryEntity.getQuery(), is("return sleep(1.1)"));
 
-			db.clearSlowQueries();
+			db.clearSlowQueries().get();
 			assertThat(db.getSlowQueries().get().size(), is(0));
 		} finally {
 			properties.setSlowQueryThreshold(slowQueryThreshold);
@@ -895,29 +895,29 @@ public void transactionVPack() throws VPackException, InterruptedException, Exec
 	}
 
 	@Test
-	public void transactionEmpty() {
-		db.transaction("function () {}", null, null);
+	public void transactionEmpty() throws InterruptedException, ExecutionException {
+		db.transaction("function () {}", null, null).get();
 	}
 
 	@Test
-	public void transactionallowImplicit() {
+	public void transactionallowImplicit() throws InterruptedException, ExecutionException {
 		try {
-			db.createCollection("someCollection", null);
-			db.createCollection("someOtherCollection", null);
+			db.createCollection("someCollection", null).get();
+			db.createCollection("someOtherCollection", null).get();
 			final String action = "function (params) {" + "var db = require('internal').db;"
 					+ "return {'a':db.someCollection.all().toArray()[0], 'b':db.someOtherCollection.all().toArray()[0]};"
 					+ "}";
 			final TransactionOptions options = new TransactionOptions().readCollections("someCollection");
-			db.transaction(action, VPackSlice.class, options);
+			db.transaction(action, VPackSlice.class, options).get();
 			try {
 				options.allowImplicit(false);
 				db.transaction(action, VPackSlice.class, options).get();
 				fail();
 			} catch (final Exception e) {
 			}
 		} finally {
-			db.collection("someCollection").drop();
-			db.collection("someOtherCollection").drop();
+			db.collection("someCollection").drop().get();
+			db.collection("someOtherCollection").drop().get();
 		}
 	}