Skip to content

Commit 5ff399e

Browse files
committed
fixed updateEdge async test
1 parent 5c320cb commit 5ff399e

File tree

1 file changed

+20
-4
lines changed

1 file changed

+20
-4
lines changed

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

Lines changed: 20 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,18 +21,33 @@
2121
package com.arangodb.async;
2222

2323

24-
import com.arangodb.entity.*;
25-
import com.arangodb.model.*;
24+
import com.arangodb.entity.ArangoDBEngine;
25+
import com.arangodb.entity.BaseDocument;
26+
import com.arangodb.entity.BaseEdgeDocument;
27+
import com.arangodb.entity.EdgeDefinition;
28+
import com.arangodb.entity.EdgeEntity;
29+
import com.arangodb.entity.StreamTransactionEntity;
30+
import com.arangodb.entity.VertexEntity;
31+
import com.arangodb.model.EdgeCreateOptions;
32+
import com.arangodb.model.EdgeDeleteOptions;
33+
import com.arangodb.model.EdgeReplaceOptions;
34+
import com.arangodb.model.EdgeUpdateOptions;
35+
import com.arangodb.model.GraphDocumentReadOptions;
36+
import com.arangodb.model.StreamTransactionOptions;
37+
import com.arangodb.model.VertexCreateOptions;
38+
import com.arangodb.model.VertexDeleteOptions;
39+
import com.arangodb.model.VertexReplaceOptions;
40+
import com.arangodb.model.VertexUpdateOptions;
2641
import org.junit.After;
2742
import org.junit.Test;
2843

2944
import java.util.Collections;
3045
import java.util.concurrent.ExecutionException;
3146

3247
import static org.hamcrest.CoreMatchers.notNullValue;
48+
import static org.hamcrest.MatcherAssert.assertThat;
3349
import static org.hamcrest.Matchers.is;
3450
import static org.hamcrest.Matchers.nullValue;
35-
import static org.hamcrest.MatcherAssert.assertThat;
3651
import static org.junit.Assume.assumeTrue;
3752

3853
/**
@@ -343,7 +358,8 @@ public void updateEdge() throws ExecutionException, InterruptedException {
343358
// update edge from within the tx
344359
doc.getProperties().clear();
345360
doc.addAttribute("test", "bar");
346-
edgeCollection.updateEdge(createdDoc.getKey(), doc, new EdgeUpdateOptions().streamTransactionId(tx.getId()));
361+
edgeCollection.updateEdge(createdDoc.getKey(), doc, new EdgeUpdateOptions().streamTransactionId(tx.getId()))
362+
.get();
347363

348364
// assert that the edge has not been updated from outside the tx
349365
assertThat(edgeCollection.getEdge(createdDoc.getKey(), BaseEdgeDocument.class, null).get()

0 commit comments

Comments
 (0)