Поправка рассылки сообщений
This commit is contained in:
@@ -28,8 +28,10 @@ class BookManager {
|
|||||||
this.recent = {};
|
this.recent = {};
|
||||||
|
|
||||||
this.recentLast = await bmRecentStore.getItem('recent-last');
|
this.recentLast = await bmRecentStore.getItem('recent-last');
|
||||||
if (this.recentLast)
|
if (this.recentLast) {
|
||||||
this.recent[this.recentLast.key] = this.recentLast;
|
this.recent[this.recentLast.key] = this.recentLast;
|
||||||
|
// let meta = await bmMetaStore.getItem(key);
|
||||||
|
}
|
||||||
|
|
||||||
this.recentRev = await bmRecentStore.getItem('recent-rev') || 0;
|
this.recentRev = await bmRecentStore.getItem('recent-rev') || 0;
|
||||||
this.recentDiffRev = await bmRecentStore.getItem('recent-diff-rev') || 0;
|
this.recentDiffRev = await bmRecentStore.getItem('recent-diff-rev') || 0;
|
||||||
@@ -470,13 +472,10 @@ class BookManager {
|
|||||||
|
|
||||||
emit(eventName, value) {
|
emit(eventName, value) {
|
||||||
if (this.eventListeners) {
|
if (this.eventListeners) {
|
||||||
(async() => {
|
for (const listener of this.eventListeners) {
|
||||||
await utils.sleep(1);//неблокирующая рассылка сообщений
|
//console.log(eventName);
|
||||||
for (const listener of this.eventListeners) {
|
listener(eventName, value);
|
||||||
//console.log(eventName);
|
}
|
||||||
listener(eventName, value);
|
|
||||||
}
|
|
||||||
})();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user