|
18 | 18 | import org.elasticsearch.index.query.TermQueryBuilder; |
19 | 19 | import org.jnosql.diana.api.document.Document; |
20 | 20 | import org.jnosql.diana.api.document.DocumentCollectionManager; |
21 | | -import org.jnosql.diana.api.document.DocumentCollectionManagerAsync; |
22 | 21 | import org.jnosql.diana.api.document.DocumentDeleteQuery; |
23 | 22 | import org.jnosql.diana.api.document.DocumentEntity; |
24 | 23 | import org.jnosql.diana.api.document.DocumentQuery; |
|
27 | 26 | import org.junit.jupiter.api.Test; |
28 | 27 |
|
29 | 28 | import java.util.List; |
| 29 | +import java.util.concurrent.atomic.AtomicBoolean; |
30 | 30 | import java.util.concurrent.atomic.AtomicReference; |
31 | 31 |
|
32 | 32 | import static org.elasticsearch.index.query.QueryBuilders.termQuery; |
@@ -107,9 +107,14 @@ public void shouldUserSearchBuilder() { |
107 | 107 | entityManager.insert(entity); |
108 | 108 | TermQueryBuilder query = termQuery("name", "Poliana"); |
109 | 109 | AtomicReference<List<DocumentEntity>> result = new AtomicReference<>(); |
| 110 | + AtomicBoolean atomicBoolean = new AtomicBoolean(false); |
110 | 111 |
|
111 | | - entityManagerAsync.search(query, result::set, "person"); |
112 | | - Awaitility.await().until(() -> result == null); |
| 112 | + entityManagerAsync.search(query, l -> { |
| 113 | + result.set(l); |
| 114 | + atomicBoolean.set(true); |
| 115 | + }, "person"); |
| 116 | + |
| 117 | + Awaitility.await().untilTrue(atomicBoolean); |
113 | 118 | List<DocumentEntity> account = result.get(); |
114 | 119 | assertFalse(account.isEmpty()); |
115 | 120 | } |
|
0 commit comments