lectures/oop20250222/pubsub/MsgPublisher.cs

using ConsoleApp1.intf;

namespace ConsoleApp1.pubsub.generics
{
    internal class MsgPublisher : IPublisher<IMessage>
    {
        public List<ISubscriber<IMessage>> _subscribers = new List<ISubscriber<IMessage>>();

        public void Publish(IMessage message)
        {
            if (string.IsNullOrEmpty(message?.Text))
            {
                return;
            }
            if (_subscribers.Count == 0)
            {
                return;
            }
            // ...
            // ...
            // ...
            foreach (ISubscriber<IMessage>? subscriber in _subscribers)
            {
                if (subscriber == null)
                {
                    continue;
                }
                subscriber?.FireEvent(message);
            }
        }

        public void Subscribe(ISubscriber<IMessage> subscriber)
        {
            _subscribers.Add(subscriber);
        }
    }
}