save

balazskreith · Oct 10, 2024 · 1e20ec8 · 1e20ec8
1 parent acb5adc
commit 1e20ec8
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/collections/HamokEmitter.ts b/src/collections/HamokEmitter.ts
@@ -285,9 +285,14 @@ export class HamokEmitter<T extends HamokEmitterEventMap, M extends Record<strin
 				serializedMetaData = 'null';
 			}
 		} else serializedMetaData = 'null';
-
-		await this.connection.requestInsertEntries(new Map([ [ event as string, serializedMetaData ] ]));
+
 		this._emitter.on(event as string, listener);
+		try {
+			await this.connection.requestInsertEntries(new Map([ [ event as string, serializedMetaData ] ]));
+		} catch (err) {
+			this._emitter.off(event as string, listener);
+			throw err;
+		}
 	}
 
 	public async updateSubscriptionMetaData<K extends keyof T>(event: K, newMetaData: M, prevMetaData?: M | null): Promise<boolean> {