src/sample/XXX.Plugin.MediatR/Event/ConsumHandler.cs

（完整代码） 1KB 

using MediatR;

namespace XXX.Plugin.MediatR
{
    /// <summary>
    /// 订阅同一个对象，A和B会同时被触发执行
    /// </summary>
    public class MediatorEvent : INotification
    {
        public MediatorEvent(string message)
        {
            Message = message;
        }

        public string Message { get; }
    }

    /// <summary>
    /// 订阅A
    /// </summary>
    public class MediatorConsumAHandler : INotificationHandler<MediatorEvent>
    {
        private readonly ILogger<MediatorConsumAHandler> _logger;

        public MediatorConsumAHandler(ILogger<MediatorConsumAHandler> logger)
        {
            _logger = logger;
        }

        public Task Handle(MediatorEvent notification, CancellationToken cancellationToken)
        {
            _logger.LogWarning($"A消费者: {notification.Message}");
            return Task.CompletedTask;
        }
    }

    /// <summary>
    /// 订阅B
    /// </summary>
    public class MediatorConsumBHandler : INotificationHandler<MediatorEvent>
    {
        private readonly ILogger<MediatorConsumBHandler> _logger;

        public MediatorConsumBHandler(ILogger<MediatorConsumBHandler> logger)
        {
            _logger = logger;
        }

        public Task Handle(MediatorEvent notification, CancellationToken cancellationToken)
        {
            _logger.LogWarning($"B消费者: {notification.Message}");
            return Task.CompletedTask;
        }
    }
}

24 小时内免费解锁 3 个项目，之后 1 算力/个。 规则说明

AI 解读 AI

登录后可用，每次 10 算力，解读结果公开显示在下面。

还没有人解读过这个文件。