如何将MediatR PublishStrategy添加到现有项目

Install-Package MediatR

services.AddMediatR(typeof(Startup));

public class CustomPublishStrategy : IPublishStrategy
{
    public Task Publish<TNotification>(IEnumerable<Func<TNotification, CancellationToken, Task>> allHandlers, TNotification notification, CancellationToken cancellationToken = default)
        where TNotification : INotification
    {
        // 自定义发布策略逻辑
        // 可以根据需要选择同步或异步执行处理程序
        // 可以选择按顺序或并行执行处理程序
        // 可以添加错误处理逻辑等等

        return Task.CompletedTask;
    }
}

services.AddMediatR(typeof(Startup), options =>
{
    options.PublishStrategy = new CustomPublishStrategy();
});

public class MyController : ControllerBase
{
    private readonly IMediator _mediator;

    public MyController(IMediator mediator)
    {
        _mediator = mediator;
    }

    public async Task<IActionResult> MyAction()
    {
        var myMessage = new MyMessage();
        await _mediator.Publish(myMessage);

        // 其他逻辑
        return Ok();
    }
}