You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2019/03/18 10:13:38 UTC

[ignite] branch master updated: IGNITE-10538 Web Console: Check only distinct cluster states.

This is an automated email from the ASF dual-hosted git repository.

akuznetsov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new a188139  IGNITE-10538 Web Console: Check only distinct cluster states.
a188139 is described below

commit a188139ff1cfe5b03fd7642ee18462ff3df3eca3
Author: Alexey Kuznetsov <ak...@apache.org>
AuthorDate: Mon Mar 18 17:13:16 2019 +0700

    IGNITE-10538 Web Console: Check only distinct cluster states.
---
 .../app/configuration/components/modal-import-models/component.js    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/modules/web-console/frontend/app/configuration/components/modal-import-models/component.js b/modules/web-console/frontend/app/configuration/components/modal-import-models/component.js
index 0dbf4f1..b1439e5 100644
--- a/modules/web-console/frontend/app/configuration/components/modal-import-models/component.js
+++ b/modules/web-console/frontend/app/configuration/components/modal-import-models/component.js
@@ -21,8 +21,8 @@ import _ from 'lodash';
 import naturalCompare from 'natural-compare-lite';
 import find from 'lodash/fp/find';
 import get from 'lodash/fp/get';
-import {race, timer, merge, of, from, combineLatest, EMPTY} from 'rxjs';
-import {tap, filter, take, pluck, switchMap, map} from 'rxjs/operators';
+import {combineLatest, EMPTY, from, merge, of, race, timer} from 'rxjs';
+import {distinctUntilChanged, filter, map, pluck, switchMap, take, tap} from 'rxjs/operators';
 import ObjectID from 'bson-objectid';
 import {uniqueName} from 'app/utils/uniqueName';
 import {defaultNames} from '../../defaultNames';
@@ -1066,6 +1066,7 @@ export class ModalImportModels {
 
         this.agentIsAvailable$ = this.agentMgr.connectionSbj.pipe(
             pluck('state'),
+            distinctUntilChanged(),
             map((state) => state !== 'AGENT_DISCONNECTED')
         );