Only register observable once

elastic · Feb 3, 2020 · e5d7d58 · e5d7d58
1 parent 6188c74
commit e5d7d58
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/plugins/data/public/search/sync_search_strategy.ts b/src/plugins/data/public/search/sync_search_strategy.ts
@@ -32,12 +32,13 @@ export interface ISyncSearchRequest extends IKibanaSearchRequest {
 export const syncSearchStrategyProvider: TSearchStrategyProvider<typeof SYNC_SEARCH_STRATEGY> = (
   context: ISearchContext
 ): ISearchStrategy<typeof SYNC_SEARCH_STRATEGY> => {
+  const loadingCount$ = new BehaviorSubject(0);
+  context.core.http.addLoadingCountSource(loadingCount$);
+
   const search: ISearch<typeof SYNC_SEARCH_STRATEGY> = (
     request: ISyncSearchRequest,
     options: ISearchOptions = {}
   ) => {
-    const loadingCount$ = new BehaviorSubject(0);
-    context.core.http.addLoadingCountSource(loadingCount$);
     loadingCount$.next(loadingCount$.getValue() + 1);
 
     const response: Promise<IKibanaSearchResponse> = context.core.http.fetch({