53 lines
1.4 KiB
C#
53 lines
1.4 KiB
C#
using System.Collections.Concurrent;
|
|
|
|
namespace zero.Communication;
|
|
|
|
public class MessageAggregator : IMessageAggregator
|
|
{
|
|
readonly ConcurrentBag<IMessageSubscription> Subscription = new ConcurrentBag<IMessageSubscription>();
|
|
readonly IServiceProvider ServiceProvider;
|
|
|
|
|
|
public MessageAggregator(IServiceProvider serviceProvider)
|
|
{
|
|
ServiceProvider = serviceProvider;
|
|
}
|
|
|
|
|
|
/// <inheritdoc />
|
|
public async Task Publish<TMessage>(TMessage message) where TMessage : class, IMessage
|
|
{
|
|
IEnumerable<IMessageSubscription> subscriptions = Subscription.Where(s => s.CanDeliver<TMessage>());
|
|
|
|
foreach (IMessageSubscription subscription in subscriptions)
|
|
{
|
|
await subscription.Deliver(ServiceProvider, message);
|
|
}
|
|
}
|
|
|
|
|
|
/// <inheritdoc />
|
|
public void Subscribe<TMessage, TMessageHandler>()
|
|
where TMessage : class, IMessage
|
|
where TMessageHandler : IMessageHandler<TMessage>
|
|
{
|
|
Subscription.Add(new MessageSubscription<TMessage, TMessageHandler>());
|
|
}
|
|
}
|
|
|
|
|
|
public interface IMessageAggregator
|
|
{
|
|
/// <summary>
|
|
/// Publishes the specified message, invoking any handlers subscribed to the message.
|
|
/// </summary>
|
|
Task Publish<TMessage>(TMessage message) where TMessage : class, IMessage;
|
|
|
|
/// <summary>
|
|
/// Subscribes the specified handler to the spified message type
|
|
/// </summary>
|
|
void Subscribe<TMessage, TMessageHandler>()
|
|
where TMessage : class, IMessage
|
|
where TMessageHandler : IMessageHandler<TMessage>;
|
|
}
|