diff --git a/packages/data-source/src/DataSourceManager.ts b/packages/data-source/src/DataSourceManager.ts index d78db1db..23dd4cab 100644 --- a/packages/data-source/src/DataSourceManager.ts +++ b/packages/data-source/src/DataSourceManager.ts @@ -349,8 +349,8 @@ class DataSourceManager extends EventEmitter { DataSourceManager.waitInitSchemaList.delete(this); } - public onDataChange(id: string, path: string, callback: (newVal: any) => void) { - return this.get(id)?.onDataChange(path, callback); + public onDataChange(id: string, path: string, callback: (newVal: any) => void, options?: { immediate?: boolean }) { + return this.get(id)?.onDataChange(path, callback, options); } public offDataChange(id: string, path: string, callback: (newVal: any) => void) { diff --git a/packages/data-source/src/data-sources/Base.ts b/packages/data-source/src/data-sources/Base.ts index 49af7d08..227eaba6 100644 --- a/packages/data-source/src/data-sources/Base.ts +++ b/packages/data-source/src/data-sources/Base.ts @@ -130,8 +130,8 @@ export default class DataSource e return this.setData(data, path); } - public onDataChange(path: string, callback: (newVal: any) => void) { - this.#observedData.on(path, callback); + public onDataChange(path: string, callback: (newVal: any) => void, options?: { immediate?: boolean }) { + this.#observedData.on(path, callback, options); } public offDataChange(path: string, callback: (newVal: any) => void) {