Skip to content

Commit a55aed2

Browse files
committed
fixes API raven API
1 parent ed05619 commit a55aed2

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

ravendb-driver/src/main/java/org/jnosql/diana/ravendb/document/RavenDBDocumentCollectionManager.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232
import java.time.Clock;
3333
import java.time.Duration;
3434
import java.time.LocalDateTime;
35+
import java.util.Collections;
3536
import java.util.HashMap;
3637
import java.util.List;
3738
import java.util.Map;
@@ -186,6 +187,8 @@ private Stream<Map> getQueryMaps(DocumentQuery query, IDocumentSession session)
186187
Stream<Map> idQueryStream = queryResult.getIds().stream()
187188
.map(i -> session.load(HashMap.class, i));
188189

190+
final List<HashMap> hashMaps = queryResult.getRavenQuery().map(IEnumerableQuery::toList)
191+
.orElse(Collections.emptyList());
189192
final Stream<HashMap> queryStream = queryResult.getRavenQuery()
190193
.map(IEnumerableQuery::toList)
191194
.map(List::stream).orElseGet(() -> Stream.empty());

ravendb-driver/src/test/java/org/jnosql/diana/ravendb/document/RavenDBDocumentCollectionManagerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -264,7 +264,7 @@ public void shouldFindDocumentIn() throws InterruptedException {
264264
.and("type").eq("V")
265265
.build();
266266
Thread.sleep(TIME_LIMIT);
267-
assertEquals(entities, entityManager.select(query));
267+
assertEquals(entities, entityManager.select(query).collect(Collectors.toList()));
268268
}
269269

270270
@Test

0 commit comments

Comments
 (0)