Subscription.cs 456 B

12345678910111213141516171819202122
  1. using System;
  2. namespace Wayne.Lib.MessageBus
  3. {
  4. internal class Subscription<T> : SubscriptionBase
  5. {
  6. public Action<string, T> InvokeAction { get; set; }
  7. public override Type Type
  8. {
  9. get { return typeof(T); }
  10. }
  11. public override void Invoke(string topic, object data)
  12. {
  13. if (data is T)
  14. {
  15. InvokeAction(topic, (T)data);
  16. }
  17. }
  18. }
  19. }