Fix exception not shown

shoothzj · Aug 2, 2021 · 25fd003 · 25fd003
1 parent 164c9e5
commit 25fd003
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 12 deletions.
diff --git a/lib/api/pulsar/pulsar_cluster_api.dart b/lib/api/pulsar/pulsar_cluster_api.dart
@@ -17,9 +17,8 @@ class PulsarClusterAPi {
     }
     String version = versionResponse.body;
 
-    String tenantInfo = "";
-    await PulsarTenantAPi.getTenantInfo(host, port, "public")
-        .then((value) => tenantInfo = value);
+    String tenantInfo =
+        await PulsarTenantAPi.getTenantInfo(host, port, "public");
     String cluster =
         ((json.decode(tenantInfo) as Map)["allowedClusters"] as List)[0];
     url = 'http://$host:${port.toString()}/admin/v2/brokers/$cluster';
@@ -40,11 +39,8 @@ class PulsarClusterAPi {
     }
     String leader = json.decode(leaderBrokerResponse.body)["serviceUrl"];
 
-    List<ClusterResp> respList = new List.empty(growable: true);
-    brokers.forEach((element) {
-      respList.add(new ClusterResp(
-          element, leader.contains(element).toString(), version));
-    });
-    return respList;
+    return brokers
+        .map((e) => ClusterResp(e, leader.contains(e).toString(), version))
+        .toList();
   }
 }
diff --git a/lib/vm/pulsar/pulsar_cluster_view_model.dart b/lib/vm/pulsar/pulsar_cluster_view_model.dart
@@ -1,8 +1,7 @@
 import 'package:paas_dashboard_flutter/api/pulsar/pulsar_cluster_api.dart';
 import 'package:paas_dashboard_flutter/module/pulsar/pulsar_cluster.dart';
 import 'package:paas_dashboard_flutter/persistent/po/pulsar_instance_po.dart';
-
-import '../base_load_list_page_view_model.dart';
+import 'package:paas_dashboard_flutter/vm/base_load_list_page_view_model.dart';
 
 class PulsarClusterViewModel extends BaseLoadListPageViewModel<ClusterResp> {
   List<ClusterResp> instances = <ClusterResp>[];
@@ -31,11 +30,11 @@ class PulsarClusterViewModel extends BaseLoadListPageViewModel<ClusterResp> {
     try {
       this.fullList = await PulsarClusterAPi.cluster(host, port);
       this.displayList = this.fullList;
+      loadSuccess();
     } on Exception catch (e) {
       loadException = e;
       loading = false;
     }
-    loadSuccess();
     notifyListeners();
   }