diff --git a/packages/data-source/src/DataSourceManager.ts b/packages/data-source/src/DataSourceManager.ts index 637d0999..1f9a44b1 100644 --- a/packages/data-source/src/DataSourceManager.ts +++ b/packages/data-source/src/DataSourceManager.ts @@ -94,11 +94,15 @@ class DataSourceManager extends EventEmitter { } }); - await Promise.all(beforeInit.map((method) => method({ params: {}, dataSource: ds, app: this.app }))); + for (const method of beforeInit) { + await method({ params: {}, dataSource: ds, app: this.app }); + } await ds.init(); - await Promise.all(afterInit.map((method) => method({ params: {}, dataSource: ds, app: this.app }))); + for (const method of afterInit) { + await method({ params: {}, dataSource: ds, app: this.app }); + } this.setData(ds); diff --git a/packages/data-source/src/data-sources/Http.ts b/packages/data-source/src/data-sources/Http.ts index e4d74865..bbb50233 100644 --- a/packages/data-source/src/data-sources/Http.ts +++ b/packages/data-source/src/data-sources/Http.ts @@ -119,18 +119,18 @@ export default class HttpDataSource extends DataSource { public async request(options: HttpOptions) { try { - await Promise.all( - this.beforeRequest.map((method) => method({ options, params: {}, dataSource: this, app: this.app })), - ); + for (const method of this.beforeRequest) { + await method({ options, params: {}, dataSource: this, app: this.app }); + } const res = await this.fetch?.({ ...this.httpOptions, ...options, }); - await Promise.all( - this.afterRequest.map((method) => method({ res, options, params: {}, dataSource: this, app: this.app })), - ); + for (const method of this.afterRequest) { + await method({ res, options, params: {}, dataSource: this, app: this.app }); + } if (this.schema.responseOptions?.dataPath) { const data = getValueByKeyPath(this.schema.responseOptions.dataPath, res);