Fix tests

Author: mpv1989

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

@@ -871,7 +871,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()));
 		final Collection<IndexEntity> indexes = f.get();

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

@@ -129,7 +129,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();
 		}
 	}
 
@@ -145,7 +145,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();
 		}
 	}
 
@@ -164,7 +164,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();
 		}
 	}
 
@@ -182,7 +182,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();
 		}
 	}
 
@@ -751,7 +751,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);
@@ -853,29 +853,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();
 		}
 	}