Function [Symbol.asyncIterator]

test/unit/persisters/common/databases.ts:157–170

()

    },
    onChange: ({signal} = {}) => ({
      async *[Symbol.asyncIterator]() {
        signal?.addEventListener('abort', noop);
        while (!signal?.aborted) {
          const nextChange = await new Promise<WatchOnChangeEvent>(
            (resolve) => {
              const observer = (_1: any, _2: any, tableName: string) => {
                resolve({changedTables: [tableName]});
              };
              sqlite3.update_hook(db, observer);
            },
          );
          yield nextChange;
        }
      },
    }),
  };
};