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 = {};