From dc37d4e8bd35d473c3c74a7b10b3d9e6af00d759 Mon Sep 17 00:00:00 2001 From: roymondchen Date: Wed, 21 May 2025 16:27:49 +0800 Subject: [PATCH] =?UTF-8?q?feat(data-source):=20=E6=96=B0=E5=A2=9E?= =?UTF-8?q?=E5=88=A4=E6=96=AD=E6=89=80=E6=9C=89=E6=95=B0=E6=8D=AE=E6=BA=90?= =?UTF-8?q?=E5=8A=A0=E8=BD=BD=E5=AE=8C=E6=88=90=E7=9A=84=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- packages/data-source/src/DataSourceManager.ts | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/packages/data-source/src/DataSourceManager.ts b/packages/data-source/src/DataSourceManager.ts index 5ae1f0d6..640366a8 100644 --- a/packages/data-source/src/DataSourceManager.ts +++ b/packages/data-source/src/DataSourceManager.ts @@ -203,7 +203,7 @@ class DataSourceManager extends EventEmitter { this.setData(ds, changeEvent); }); - if (!this.app.dsl?.dataSources || this.dataSourceMap.size === this.app.dsl.dataSources.length) { + if (this.isAllDataSourceRegistered()) { this.emit('registered-all'); } @@ -328,6 +328,10 @@ class DataSourceManager extends EventEmitter { ); } + public isAllDataSourceRegistered() { + return !this.app.dsl?.dataSources?.length || this.dataSourceMap.size === this.app.dsl.dataSources.length; + } + public destroy() { this.removeAllListeners(); this.data = {};