Bugfix: concurrent modifications during iteration occurred in some cases while processing events.

Author: Mad Sheogorath

CHANGELOG.md

@@ -1,3 +1,6 @@
+## v1.1.3
+* Bugfix: concurrent modifications during iteration occurred in some cases while processing events.
+
 ## v1.1.2
 * Bugfix: expireAfterSeconds option for IndexDescriptor of CollectionDescriptor was ignored.
 

lib/core/events.dart

@@ -60,18 +60,23 @@ class Events {
 		_eventHandlers[T]?.remove(handler);
 	}
 
+	Future<void> _tryExecute(Function handler, Event event) async {
+		try {
+			await handler(event);
+		}
+		catch (err, stack) {
+			_server._logger.error('Event handler execution error: $err', stack);
+		}
+	}
+
 	Future<void> dispatch(Event event) async {
-		if (event is! Event) throw Exception('$event is not an Event class instance');
+		final List<Future<void>> futures = <Future<void>>[];
 		if (_eventHandlers[event.runtimeType] != null) {
 			for (final Function handler in _eventHandlers[event.runtimeType]!) {
-				try {
-					await handler(event);
-				}
-				catch (err, stack) {
-					_server._logger.error('Event handler execution error: $err', stack);
-				}
+				futures.add(_tryExecute(handler, event));
 			}
 		}
+		await Future.wait(futures);
 	}
 
 	void dispose() {

pubspec.yaml

@@ -1,6 +1,6 @@
 name: serveme
 description: Backend server framework designed for a quick development of modular WebSocket based server applications with MongoDB integration.
-version: 1.1.2
+version: 1.1.3
 homepage: https://github.com/sourcecaster/serveme
 repository: https://github.com/sourcecaster/serveme
 issue_tracker: https://github.com/sourcecaster/serveme/issues