fixes parser

eclipse · Apr 7, 2018 · 2f9e37b · 2f9e37b
1 parent 1fcb71c
commit 2f9e37b
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/...rg/jnosql/diana/elasticsearch/document/DefaultElasticsearchDocumentCollectionManager.java b/...rg/jnosql/diana/elasticsearch/document/DefaultElasticsearchDocumentCollectionManager.java
@@ -128,7 +128,7 @@ public List<DocumentEntity> search(QueryBuilder query, String... types) throws N
             SearchResponse search = client.search(searchRequest);
 
             return stream(search.getHits().spliterator(), false)
-                    .map(h -> new ElasticsearchEntry(h.getId(), h.getIndex(), h.getSourceAsMap()))
+                    .map(ElasticsearchEntry::of)
                     .filter(ElasticsearchEntry::isNotEmpty)
                     .map(ElasticsearchEntry::toEntity)
                     .collect(Collectors.toList());

diff --git a/...earch-driver/src/main/java/org/jnosql/diana/elasticsearch/document/FindAsyncListener.java b/...earch-driver/src/main/java/org/jnosql/diana/elasticsearch/document/FindAsyncListener.java
@@ -56,7 +56,7 @@ public void onResponse(MultiGetResponse multiGetItemResponses) {
 
                 Stream.of(multiGetItemResponses.getResponses())
                         .map(MultiGetItemResponse::getResponse)
-                        .map(h -> new ElasticsearchEntry(h.getId(), collection, h.getSourceAsMap()))
+                        .map(ElasticsearchEntry::of)
                         .filter(ElasticsearchEntry::isNotEmpty)
                         .map(ElasticsearchEntry::toEntity)
                         .forEach(entities::add);
@@ -79,7 +79,7 @@ ActionListener<SearchResponse> getSearch() {
             public void onResponse(SearchResponse searchResponse) {
                 query.set(true);
                 stream(searchResponse.getHits().spliterator(), false)
-                        .map(h -> new ElasticsearchEntry(h.getId(), collection, h.getSourceAsMap()))
+                        .map(ElasticsearchEntry::of)
                         .filter(ElasticsearchEntry::isNotEmpty)
                         .map(ElasticsearchEntry::toEntity)
                         .forEach(entities::add);

diff --git a/...river/src/main/java/org/jnosql/diana/elasticsearch/document/FindQueryBuilderListener.java b/...river/src/main/java/org/jnosql/diana/elasticsearch/document/FindQueryBuilderListener.java
@@ -37,7 +37,7 @@ class FindQueryBuilderListener implements ActionListener<SearchResponse> {
     @Override
     public void onResponse(SearchResponse searchResponse) {
         List<DocumentEntity> entities = stream(searchResponse.getHits().spliterator(), false)
-                .map(h -> new ElasticsearchEntry(h.getId(), h.getIndex(), h.getSourceAsMap()))
+                .map(ElasticsearchEntry::of)
                 .filter(ElasticsearchEntry::isNotEmpty)
                 .map(ElasticsearchEntry::toEntity)
                 .collect(Collectors.toList());