12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 |
- using System;
- using System.Collections.Generic;
- using System.Linq;
- namespace Wayne.Lib.MessageBus
- {
- /// <summary>
- /// A very basic, fully synchronous bus implementation. The publish method
- /// will execute all subscribe actions.
- /// </summary>
- public class BasicBus : IBus
- {
- readonly object subscriptionsLock = new object();
- readonly List<SubscriptionBase> subscriptions = new List<SubscriptionBase>();
- public virtual void Publish(string topic, object message)
- {
- SubscriptionBase[] iterationSubscriptions;
- lock (subscriptionsLock)
- {
- iterationSubscriptions = subscriptions.ToArray();
- }
- iterationSubscriptions
- .Where(x => Any.Match(topic, x.TopicFilter))
- .Where(x => x.Type.IsInstanceOfType(message))
- .ForEach(x =>
- {
- x.Invoke(topic, message);
- });
- }
- public virtual IDisposable Subscribe<T>(string topicFilter, Action<string, T> action)
- {
- var subscription = new Subscription<T>()
- {
- TopicFilter = topicFilter,
- InvokeAction = action
- };
- lock (subscriptionsLock)
- {
- subscriptions.Add(subscription);
- }
- return new ActionDisposable(() =>
- {
- lock (subscriptionsLock)
- {
- subscriptions.Remove(subscription);
- }
- });
- }
- }
- }
|