fixes parser

Author: otaviojava

elasticsearch-driver/src/main/java/org/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());

elasticsearch-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);

elasticsearch-driver/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());