}()
_, _, _ = notifier.eventsPubsubs.GetAndDo(identifier, func(key any, value any) error {
for _, channel := range subscribers {
select {
case channel <- event:
default:
// in case the channel is already filled with message