expose scroll method through module

chris72205 · Mar 13, 2019 · 05f901a · 05f901a
1 parent 8724638
commit 05f901a
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/lib/elasticsearch.service.ts b/lib/elasticsearch.service.ts
@@ -24,7 +24,8 @@ import {
   SearchResponse,
   UpdateDocumentByQueryParams,
   UpdateDocumentByQueryResponse,
-  UpdateDocumentParams
+  UpdateDocumentParams,
+  ScrollParams
 } from 'elasticsearch';
 import { bindNodeCallback, Observable } from 'rxjs';
 import { ELASTICSEARCH_CLIENT } from './elasticsearch-client.provider';
@@ -61,6 +62,12 @@ export class ElasticsearchService {
     ) as any) as Observable<SearchResponse<T>>;
   }
 
+  scroll<T = any>(params: ScrollParams): Observable<SearchResponse<T>> {
+    return (bindNodeCallback(this.bindClientContext(this.esClient.scroll))(
+      params
+    ) as any) as Observable<SearchResponse<T>>;
+  }
+
   count(params: CountParams): Observable<CountResponse> {
     return (bindNodeCallback(this.bindClientContext(this.esClient.count))(
       params