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