lectures/oop20250222/pubsub/generics/Publisher.cs

using ConsoleApp1.intf;

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

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

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