Skip to content

Commit 541945d

Browse files
committed
bugfix missing get() in async tests
1 parent 2c2ea99 commit 541945d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/test/java/com/arangodb/async/StreamTransactionGraphTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -221,7 +221,7 @@ public void deleteVertex() throws ExecutionException, InterruptedException {
221221
.writeCollections(VERTEX_COLLECTION_1, VERTEX_COLLECTION_2, EDGE_COLLECTION)).get();
222222

223223
// delete vertex from within the tx
224-
vertexCollection1.deleteVertex(createdDoc.getKey(), new VertexDeleteOptions().streamTransactionId(tx.getId()));
224+
vertexCollection1.deleteVertex(createdDoc.getKey(), new VertexDeleteOptions().streamTransactionId(tx.getId())).get();
225225

226226
// assert that the vertex has not been deleted from outside the tx
227227
assertThat(vertexCollection1.getVertex(createdDoc.getKey(), BaseDocument.class, null).get(), is(notNullValue()));
@@ -374,7 +374,7 @@ public void deleteEdge() throws ExecutionException, InterruptedException {
374374
.writeCollections(VERTEX_COLLECTION_1, VERTEX_COLLECTION_2, EDGE_COLLECTION)).get();
375375

376376
// delete edge from within the tx
377-
edgeCollection.deleteEdge(createdDoc.getKey(), new EdgeDeleteOptions().streamTransactionId(tx.getId()));
377+
edgeCollection.deleteEdge(createdDoc.getKey(), new EdgeDeleteOptions().streamTransactionId(tx.getId())).get();
378378

379379
// assert that the edge has not been deleted from outside the tx
380380
assertThat(edgeCollection.getEdge(createdDoc.getKey(), BaseEdgeDocument.class, null).get(), is(notNullValue()));

0 commit comments

Comments
 (0)