|
21 | 21 | package com.arangodb.async; |
22 | 22 |
|
23 | 23 |
|
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; |
26 | 41 | import org.junit.After; |
27 | 42 | import org.junit.Test; |
28 | 43 |
|
29 | 44 | import java.util.Collections; |
30 | 45 | import java.util.concurrent.ExecutionException; |
31 | 46 |
|
32 | 47 | import static org.hamcrest.CoreMatchers.notNullValue; |
| 48 | +import static org.hamcrest.MatcherAssert.assertThat; |
33 | 49 | import static org.hamcrest.Matchers.is; |
34 | 50 | import static org.hamcrest.Matchers.nullValue; |
35 | | -import static org.hamcrest.MatcherAssert.assertThat; |
36 | 51 | import static org.junit.Assume.assumeTrue; |
37 | 52 |
|
38 | 53 | /** |
@@ -343,7 +358,8 @@ public void updateEdge() throws ExecutionException, InterruptedException { |
343 | 358 | // update edge from within the tx |
344 | 359 | doc.getProperties().clear(); |
345 | 360 | 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(); |
347 | 363 |
|
348 | 364 | // assert that the edge has not been updated from outside the tx |
349 | 365 | assertThat(edgeCollection.getEdge(createdDoc.getKey(), BaseEdgeDocument.class, null).get() |
|
0 commit comments