* Switched to multi-target netstandard1.1 and netstandard2.0

*  Some minor code cleanup (lots of switching to lamda expressions since so many methods were single-line)
*  Ignored .vs folder

Author: upta

.gitignore

@@ -6,6 +6,8 @@
 *.user
 *.sln.docstates
 
+.vs/
+
 # Build results
 
 [Dd]ebug/

.vs/config/applicationhost.config

@@ -16,53 +16,67 @@ public class Hub
         /// </summary>
         /// <typeparam name="T"></typeparam>
         /// <param name="data"></param>
-        public void Publish<T>(T data = default(T))
+        public void Publish<T>( T data = default( T ) )
         {
-            Publish(this, data);
+            Publish( this, data );
         }
 
-        public void Publish<T>(object sender, T data = default(T))
+        public void Publish<T>( object sender, T data = default( T ) )
         {
             List<Handler> handlerList;
 
-            lock (locker)
+            lock ( locker )
             {
-                handlerList = new List<Handler>(handlers.Count);
-                var handlersToRemoveList = new List<Handler>(handlers.Count);
-                foreach (var handler in handlers)
-                    if (!handler.Sender.IsAlive)
-                        handlersToRemoveList.Add(handler);
-                    else if (handler.Type.GetTypeInfo().IsAssignableFrom(typeof(T).GetTypeInfo()))
-                        handlerList.Add(handler);
-
-                foreach (var l in handlersToRemoveList) handlers.Remove(l);
+                handlerList = new List<Handler>( handlers.Count );
+
+                var handlersToRemove = new List<Handler>( handlers.Count );
+
+                foreach ( var handler in handlers )
+                {
+                    if ( !handler.Sender.IsAlive )
+                    {
+                        handlersToRemove.Add( handler );
+                    }
+                    else if ( handler.Type.GetTypeInfo().IsAssignableFrom( typeof( T ).GetTypeInfo() ) )
+                    {
+                        handlerList.Add( handler );
+                    }
+                }
+
+                foreach ( var l in handlersToRemove )
+                {
+                    handlers.Remove( l );
+                }
             }
 
-            foreach (var l in handlerList) ((Action<T>) l.Action)(data);
+            foreach ( var l in handlerList )
+            {
+                ( (Action<T>) l.Action )( data );
+            }
         }
 
         /// <summary>
         ///     Allow subscribing directly to this Hub.
         /// </summary>
         /// <typeparam name="T"></typeparam>
         /// <param name="handler"></param>
-        public void Subscribe<T>(Action<T> handler)
+        public void Subscribe<T>( Action<T> handler )
         {
-            Subscribe(this, handler);
+            Subscribe( this, handler );
         }
 
-        public void Subscribe<T>(object subscriber, Action<T> handler)
+        public void Subscribe<T>( object subscriber, Action<T> handler )
         {
             var item = new Handler
             {
                 Action = handler,
-                Sender = new WeakReference(subscriber),
-                Type = typeof(T)
+                Sender = new WeakReference( subscriber ),
+                Type = typeof( T )
             };
 
-            lock (locker)
+            lock ( locker )
             {
-                handlers.Add(item);
+                handlers.Add( item );
             }
         }
 
@@ -71,17 +85,20 @@ public void Subscribe<T>(object subscriber, Action<T> handler)
         /// </summary>
         public void Unsubscribe()
         {
-            Unsubscribe(this);
+            Unsubscribe( this );
         }
 
-        public void Unsubscribe(object subscriber)
+        public void Unsubscribe( object subscriber )
         {
-            lock (locker)
+            lock ( locker )
             {
-                var query = handlers.Where(a => !a.Sender.IsAlive ||
-                                                a.Sender.Target.Equals(subscriber));
+                var query = handlers.Where( a => !a.Sender.IsAlive ||
+                                                 a.Sender.Target.Equals( subscriber ) );
 
-                foreach (var h in query.ToList()) handlers.Remove(h);
+                foreach ( var h in query.ToList() )
+                {
+                    handlers.Remove( h );
+                }
             }
         }
 
@@ -91,55 +108,68 @@ public void Unsubscribe(object subscriber)
         /// <typeparam name="T"></typeparam>
         public void Unsubscribe<T>()
         {
-            Unsubscribe<T>(this);
+            Unsubscribe<T>( this );
         }
 
         /// <summary>
         ///     Allow unsubscribing directly to this Hub.
         /// </summary>
         /// <typeparam name="T"></typeparam>
         /// <param name="handler"></param>
-        public void Unsubscribe<T>(Action<T> handler)
+        public void Unsubscribe<T>( Action<T> handler )
         {
-            Unsubscribe(this, handler);
+            Unsubscribe( this, handler );
         }
 
-        public void Unsubscribe<T>(object subscriber, Action<T> handler = null)
+        public void Unsubscribe<T>( object subscriber, Action<T> handler = null )
         {
-            lock (locker)
+            lock ( locker )
             {
-                var query = handlers
-                    .Where(a => !a.Sender.IsAlive ||
-                                a.Sender.Target.Equals(subscriber) && a.Type == typeof(T));
-
-                if (handler != null) query = query.Where(a => a.Action.Equals(handler));
-
-                foreach (var h in query.ToList()) handlers.Remove(h);
+                var query = handlers.Where( a => !a.Sender.IsAlive ||
+                                                 a.Sender.Target.Equals( subscriber ) && a.Type == typeof( T ) );
+
+                if ( handler != null )
+                {
+                    query = query.Where( a => a.Action.Equals( handler ) );
+                }
+
+                foreach ( var h in query.ToList() )
+                {
+                    handlers.Remove( h );
+                }
             }
         }
 
-        public bool Exists<T>(object subscriber)
+        public bool Exists<T>( object subscriber )
         {
-            lock (locker)
+            lock ( locker )
             {
-                foreach (var h in handlers)
-                    if (Equals(h.Sender.Target, subscriber) &&
-                        typeof(T) == h.Type)
+                foreach ( var h in handlers )
+                {
+                    if ( Equals( h.Sender.Target, subscriber ) &&
+                         typeof( T ) == h.Type )
+                    {
                         return true;
+                    }
+                }
             }
 
             return false;
         }
 
-        public bool Exists<T>(object subscriber, Action<T> handler)
+        public bool Exists<T>( object subscriber, Action<T> handler )
         {
-            lock (locker)
+            lock ( locker )
             {
-                foreach (var h in handlers)
-                    if (Equals(h.Sender.Target, subscriber) &&
-                        typeof(T) == h.Type &&
-                        h.Action.Equals(handler))
+                foreach ( var h in handlers )
+                {
+                    if ( Equals( h.Sender.Target, subscriber ) &&
+                         typeof( T ) == h.Type &&
+                         h.Action.Equals( handler ) )
+                    {
                         return true;
+                    }
+                }
             }
 
             return false;

PubSub/Core/Hub.cs

@@ -7,39 +7,19 @@ public static class PubSubExtensions
     {
         private static readonly Hub hub = new Hub();
 
-        public static void Publish<T>(this object obj)
-        {
-            hub.Publish(obj, default(T));
-        }
-
-        public static void Publish<T>(this object obj, T data)
-        {
-            hub.Publish(obj, data);
-        }
-
-        public static void Subscribe<T>(this object obj, Action<T> handler)
-        {
-            hub.Subscribe(obj, handler);
-        }
-
-        public static void Unsubscribe(this object obj)
-        {
-            hub.Unsubscribe(obj);
-        }
-
-        public static void Unsubscribe<T>(this object obj)
-        {
-            hub.Unsubscribe(obj, (Action<T>) null);
-        }
-
-        public static void Unsubscribe<T>(this object obj, Action<T> handler)
-        {
-            hub.Unsubscribe(obj, handler);
-        }
-
-        public static bool Exists<T>(this object obj)
-        {
-            return hub.Exists<T>(obj);
-        }
+
+        public static bool Exists<T>( this object obj ) => hub.Exists<T>( obj );
+
+        public static void Publish<T>( this object obj ) => hub.Publish( obj, default( T ) );
+
+        public static void Publish<T>( this object obj, T data ) => hub.Publish( obj, data );
+
+        public static void Subscribe<T>( this object obj, Action<T> handler ) => hub.Subscribe( obj, handler );
+
+        public static void Unsubscribe( this object obj ) => hub.Unsubscribe( obj );
+
+        public static void Unsubscribe<T>( this object obj ) => hub.Unsubscribe( obj, (Action<T>) null );
+
+        public static void Unsubscribe<T>( this object obj, Action<T> handler ) => hub.Unsubscribe( obj, handler );
     }
 }

PubSub/Extension/PubSubExtensions.cs

@@ -11,15 +11,9 @@ public PubSubPipelineFactory()
             hub = new Hub();
         }
 
-        
-        public IPublisher GetPublisher()
-        {
-            return new Publisher(hub);
-        }
 
-        public ISubscriber GetSubscriber()
-        {
-            return new Subscriber(hub);
-        }
+        public IPublisher GetPublisher() => new Publisher( hub );
+
+        public ISubscriber GetSubscriber() => new Subscriber( hub );
     }
 }

PubSub/Ioc/Implementation/PubSubPipeLineFactory.cs

@@ -5,14 +5,12 @@ namespace PubSub
     public class Publisher : IPublisher
     {
         private readonly Hub hub;
-        public Publisher(Hub hub)
+
+        public Publisher( Hub hub )
         {
             this.hub = hub;
         }
 
-        public void Publish<T>(object sender,T data )
-        {
-            hub.Publish(sender, data);
-        }
+        public void Publish<T>( object sender, T data ) => hub.Publish( sender, data );
     }
 }

PubSub/Ioc/Implementation/Publisher.cs

@@ -5,40 +5,23 @@ namespace PubSub
 {
     public class Subscriber : ISubscriber
     {
-        public Subscriber(Hub hub)
+        private readonly Hub hub;
+
+        public Subscriber( Hub hub )
         {
             this.hub = hub;
         }
 
-        private readonly Hub hub;
-        public void Subscribe<T>(object subscriber, Action<T> handler )
-        {
-            hub.Subscribe( subscriber, handler );
-        }
+        public bool Exists<T>( object subscriber ) => hub.Exists<T>( subscriber );
 
-        public void Unsubscribe(object subscriber )
-        {
-            hub.Unsubscribe( subscriber );
-        }
+        public bool Exists<T>( object subscriber, Action<T> handler ) => hub.Exists( subscriber, handler );
 
-        public void Unsubscribe<T>(object subscriber )
-        {
-            hub.Unsubscribe( subscriber, (Action<T>) null );
-        }
+        public void Subscribe<T>( object subscriber, Action<T> handler ) => hub.Subscribe( subscriber, handler );
 
-        public void Unsubscribe<T>(object subscriber, Action<T> handler )
-        {
-            hub.Unsubscribe( subscriber, handler );
-        }
+        public void Unsubscribe( object subscriber ) => hub.Unsubscribe( subscriber );
 
-        public bool Exists<T>(object subscriber)
-        {
-            return hub.Exists<T>(subscriber);
-        }
+        public void Unsubscribe<T>( object subscriber ) => hub.Unsubscribe( subscriber, (Action<T>) null );
 
-        public bool Exists<T>(object subscriber, Action<T> handler)
-        {
-            return hub.Exists<T>(subscriber, handler);
-        }
+        public void Unsubscribe<T>( object subscriber, Action<T> handler ) => hub.Unsubscribe( subscriber, handler );
     }
 }

PubSub/Ioc/Implementation/Subscriber.cs

@@ -2,6 +2,6 @@
 {
     public interface IPublisher
     {
-        void Publish<T>(object sender,T data);
+        void Publish<T>( object sender, T data );
     }
 }

PubSub/Ioc/Interfaces/IPublisher.cs

@@ -4,11 +4,11 @@ namespace PubSub
 {
     public interface ISubscriber
     {
-        void Subscribe<T>(object subscriber, Action<T> handler );
-        void Unsubscribe(object subscriber );
-        void Unsubscribe<T>(object subscriber );
-        void Unsubscribe<T>(object subscriber, Action<T> handler );
-        bool Exists<T>(object subscriber);
-        bool Exists<T>(object subscriber, Action<T> handler);
+        bool Exists<T>( object subscriber );
+        bool Exists<T>( object subscriber, Action<T> handler );
+        void Subscribe<T>( object subscriber, Action<T> handler );
+        void Unsubscribe( object subscriber );
+        void Unsubscribe<T>( object subscriber );
+        void Unsubscribe<T>( object subscriber, Action<T> handler );
     }
 }