wabbajack/Wabbajack.App/MessageBus.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Reactive.Disposables;
using System.Threading.Tasks;
using Avalonia.Threading;
using Microsoft.Extensions.Logging;
using Wabbajack.App.Messages;

namespace Wabbajack.App
{
    public class MessageBus
    {
        public static MessageBus Instance { get; private set; }
        private readonly IReceiverMarker[] _receivers;
        private readonly ILogger<MessageBus> _logger;

        public MessageBus(ILogger<MessageBus> logger, IEnumerable<IReceiverMarker> receivers)
        {
            Instance = this;
            _receivers = receivers.ToArray();
            _logger = logger;
        }

        public void Send<T>(T message)
        {
            AvaloniaScheduler.Instance.Schedule(message, TimeSpan.FromMilliseconds(200), (_, msg) =>
            {
                foreach (var receiver in _receivers.OfType<IReceiver<T>>())
                {
                    _logger.LogInformation("Sending {msg} to {receiver}", msg, receiver);
                    try
                    {
                        receiver.Receive(msg);
                    }
                    catch (Exception ex)
                    {
                        _logger.LogCritical(ex, "Failed sending {msg} to {receiver}", msg, receiver);
                    }
                }

                return Disposable.Empty;
            });
        }
    }
}