11 files changed, 125 insertions, 0 deletions
diff --git a/src/core/Casting.cs b/src/core/Casting.cs
new file mode 100755
index 0000000..dbc25f0
--- /dev/null
+++ b/src/core/Casting.cs
@@ -0,0 +1,10 @@
+namespace core
+{
+    public static class Casting
+    {
+        public static T DowncastTo<T>(this object item) where T : class
+        {
+            return item as T;
+        }
+    }
+}
+\ No newline at end of file
diff --git a/src/core/Dynamic.cs b/src/core/Dynamic.cs
new file mode 100755
index 0000000..ae4a627
--- /dev/null
+++ b/src/core/Dynamic.cs
@@ -0,0 +1,12 @@
+using System;
+
+namespace core
+{
+    public static class Dynamic
+    {
+        public static void CallAs<DynamicType>(this object target, Action<DynamicType> command) where DynamicType : class
+        {
+            command(target.DowncastTo<DynamicType>());
+        }
+    }
+}
+\ No newline at end of file
diff --git a/src/core/IEventAggregator.cs b/src/core/IEventAggregator.cs
new file mode 100755
index 0000000..91758f7
--- /dev/null
+++ b/src/core/IEventAggregator.cs
@@ -0,0 +1,4 @@
+namespace core
+{
+    public interface IEventAggregator : IEventRegistry, IPublishEvents {}
+}
+\ No newline at end of file
diff --git a/src/core/IEventRegistry.cs b/src/core/IEventRegistry.cs
new file mode 100755
index 0000000..db9c475
--- /dev/null
+++ b/src/core/IEventRegistry.cs
@@ -0,0 +1,7 @@
+namespace core
+{
+    public interface IEventRegistry
+    {
+        void RegisterFor<Event>(ISubscribeTo<Event> subscriber);
+    }
+}
+\ No newline at end of file
diff --git a/src/core/IPublishEvents.cs b/src/core/IPublishEvents.cs
new file mode 100755
index 0000000..af540c3
--- /dev/null
+++ b/src/core/IPublishEvents.cs
@@ -0,0 +1,7 @@
+namespace core
+{
+    public interface IPublishEvents
+    {
+        void Publish<Event>(Event theEvent);
+    }
+}
+\ No newline at end of file
diff --git a/src/core/ISubscribeTo.cs b/src/core/ISubscribeTo.cs
new file mode 100755
index 0000000..b2fd12e
--- /dev/null
+++ b/src/core/ISubscribeTo.cs
@@ -0,0 +1,7 @@
+namespace core
+{
+    public interface ISubscribeTo<Event>
+    {
+        void Notify(Event subscribedEvent);
+    }
+}
+\ No newline at end of file
diff --git a/src/core/Iterating.cs b/src/core/Iterating.cs
new file mode 100755
index 0000000..3e7de14
--- /dev/null
+++ b/src/core/Iterating.cs
@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+
+namespace core
+{
+    public static class Iterating
+    {
+        public static void Each<T>(this IEnumerable<T> items, Action<T> visitor)
+        {
+            foreach (var item in items ?? Enumerable.Empty<T>()) visitor(item);
+        }
+    }
+}
+\ No newline at end of file
diff --git a/src/core/ThreadUnsafeEventAggregator.cs b/src/core/ThreadUnsafeEventAggregator.cs
new file mode 100755
index 0000000..c0d902f
--- /dev/null
+++ b/src/core/ThreadUnsafeEventAggregator.cs
@@ -0,0 +1,19 @@
+using System.Collections.Generic;
+
+namespace core
+{
+    public class ThreadUnsafeEventAggregator : IEventAggregator
+    {
+        List<object> subscribers = new List<object>();
+
+        public void RegisterFor<Event>(ISubscribeTo<Event> subscriber)
+        {
+            subscribers.Add(subscriber);
+        }
+
+        public void Publish<Event>(Event theEvent)
+        {
+            subscribers.Each(x => x.CallAs<ISubscribeTo<Event>>(y => y.Notify(theEvent)));
+        }
+    }
+}
+\ No newline at end of file
diff --git a/src/core/core.csproj b/src/core/core.csproj
index 0808656..2f4d1cf 100755
--- a/src/core/core.csproj
+++ b/src/core/core.csproj
@@ -43,8 +43,16 @@
     <Reference Include="System.Xml" />
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="Casting.cs" />
+    <Compile Include="Dynamic.cs" />
+    <Compile Include="IEventAggregator.cs" />
+    <Compile Include="IEventRegistry.cs" />
+    <Compile Include="IPublishEvents.cs" />
+    <Compile Include="ISubscribeTo.cs" />
+    <Compile Include="Iterating.cs" />
     <Compile Include="RoboMom.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
+    <Compile Include="ThreadUnsafeEventAggregator.cs" />
   </ItemGroup>
   <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
diff --git a/src/specs/EventAggregatorSpec.cs b/src/specs/EventAggregatorSpec.cs
new file mode 100755
index 0000000..d40b9f8
--- /dev/null
+++ b/src/specs/EventAggregatorSpec.cs
@@ -0,0 +1,36 @@
+using Machine.Specifications;
+using Rhino.Mocks;
+
+namespace specs
+{
+    public class EventAggregatorSpec
+    {
+        Establish context = () =>
+        {
+            sut = new ThreadUnsafeEventAggregator();
+        };
+
+        static IEventAggregator sut;
+
+        public class when_publishing
+        {
+            It should_notify_all_interested_subscribers = () =>
+            {
+                handler.AssertWasCalled(x => x.Notify("hello"));
+            };
+
+            Establish context = () =>
+            {
+                handler = MockRepository.GenerateMock<ISubscribeTo<string>>();
+            };
+
+            Because of = () =>
+            {
+                sut.RegisterFor(handler);
+                sut.Publish("hello");
+            };
+
+            static ISubscribeTo<string> handler;
+        }
+    }
+}
+\ No newline at end of file
diff --git a/src/specs/specs.csproj b/src/specs/specs.csproj
index afcb377..d0ecf7c 100755
--- a/src/specs/specs.csproj
+++ b/src/specs/specs.csproj
@@ -52,6 +52,7 @@
     <Reference Include="System.Xml" />
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="EventAggregatorSpec.cs" />
     <Compile Include="RoboMomSpecs.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
   </ItemGroup>