fork download

 
//некое событие
public interface IEvent{}
 
//обработчик события
public interface IEventHandler<T> where T : class, IEvent
{
    public void HandleEvent(T @event);
}
 
public class EventDispatcher{
    private Dictionary<Type, List<WeakReference>> _handlers = new();
    private object _locker = new();
    public void Subscribe<T>(IEventHandler<T> handler) where T : class, IEvent
    {
        var type = typeof(T);
        lock(_locker){
            if(!_handlers.TryGetValue(type, out var handlers)){
                handlers = new();
                _handlers[type] = handlers;
            }
            var refs = handlers.Find(x=>x.Target == handler);
            if(refs is not null){
                throw new InvalidOperationException();
            }
            refs = new(handler);
            handlers.Add(refs);            
        }
    }
 
    public void Unsubscribe<T>(IEventHandler<T> handler) where T : class, IEvent
    {
        var type = typeof(T);
        lock(_locker){
            if(!_handlers.ContainsKey(type)){
                throw new InvalidOperationException();
            }
            var handlers = _handlers[type];
            var refs = handlers.Find(x=>x.Target == handlers);
            if(refs is null){
                throw new InvalidOperationException();
            }
            handlers.Remove(refs);
        }
    }
 
    public void Handle<T>(T @event) where T : class, IEvent
    {
        var type = typeof(T);
        //не даем подписываться пока идет обработка)))
        lock(_locker){
            if(!_handlers.ContainsKey(type)){
                return;
            }
            var handlers = _handlers[type];
            List<WeakReference> toRemove = new();
            foreach(var handlerRef in handlers){
                if(!handlerRef.IsAlive){
                    toRemove.Add(handlerRef);
                    continue;
                }
                if(handlerRef.Target is null){
                    toRemove.Add(handlerRef);
                    continue;
                }
                var handler = handlerRef.Target as IEventHandler<T>;
                if(handler is null){
                    toRemove.Add(handlerRef);
                    continue;
                }
                handler.HandleEvent(@event);
            }
            foreach(var i in toRemove){
                handlers.Remove(i);
            }
        }
    }
}

prog.cs(8,17): error CS0106: The modifier `public' is not valid for this item
prog.cs(12,66): error CS1525: Unexpected symbol `)', expecting `(' or `type'
prog.cs(13,33): error CS1525: Unexpected symbol `)', expecting `(' or `type'
prog.cs(19,31): error CS1525: Unexpected symbol `)', expecting `(' or `type'
prog.cs(23,27): error CS1525: Unexpected symbol `null'
prog.cs(26,23): error CS8124: Tuple must contain at least two elements
prog.cs(26,31): error CS1525: Unexpected symbol `;', expecting `(', `[', or `{'
prog.cs(40,21): error CS1644: Feature `pattern matching' cannot be used because it is not part of the C# 7.0 language specification
prog.cs(56,47): error CS1525: Unexpected symbol `)', expecting `(' or `type'
prog.cs(62,38): error CS1644: Feature `pattern matching' cannot be used because it is not part of the C# 7.0 language specification
prog.cs(67,28): error CS1644: Feature `pattern matching' cannot be used because it is not part of the C# 7.0 language specification
Compilation failed: 11 error(s), 0 warnings

Standard output is empty