diff --git a/Octokit.Reactive/Clients/IObservableActivityClient.cs b/Octokit.Reactive/Clients/IObservableActivityClient.cs
new file mode 100644
index 00000000..e371e8da
--- /dev/null
+++ b/Octokit.Reactive/Clients/IObservableActivityClient.cs
@@ -0,0 +1,99 @@
+using System;
+
+namespace Octokit.Reactive
+{
+    public interface IObservableActivityClient
+    {
+        /// <summary>
+        /// Gets all the public events
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events
+        /// </remarks>
+        /// <returns>All the public <see cref="Activity"/>s for the particular user.</returns>
+        IObservable<Activity> GetAll();
+
+        /// <summary>
+        /// Gets all the events for a given repository
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-issue-events-for-a-repository
+        /// </remarks>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="name">The name of the repository</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular repository.</returns>
+        IObservable<Activity> GetAllForRepository(string owner, string name);
+
+        /// <summary>
+        /// Gets all the events for a given repository network
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-for-a-network-of-repositories
+        /// </remarks>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="name">The name of the repository</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular repository network.</returns>
+        IObservable<Activity> GetAllForRepositoryNetwork(string owner, string name);
+
+        /// <summary>
+        /// Gets all the events for a given organization
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-for-an-organization
+        /// </remarks>
+        /// <param name="organization">The name of the organization</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular organization.</returns>
+        IObservable<Activity> GetAllForOrganization(string organization);
+
+        /// <summary>
+        /// Gets all the events that have been received by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-that-a-user-has-received
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has received.</returns>
+        IObservable<Activity> GetUserReceived(string user);
+
+        /// <summary>
+        /// Gets all the events that have been received by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-that-a-user-has-received
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has received.</returns>
+        IObservable<Activity> GetUserReceivedPublic(string user);
+
+        /// <summary>
+        /// Gets all the events that have been performed by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-performed-by-a-user
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has performed.</returns>
+        IObservable<Activity> GetUserPerformed(string user);
+
+        /// <summary>
+        /// Gets all the public events that have been performed by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-performed-by-a-user
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the public <see cref="Activity"/>s that a particular user has performed.</returns>
+        IObservable<Activity> GetUserPerformedPublic(string user);
+
+        /// <summary>
+        /// Gets all the events that are associated with an organization.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-for-an-organization
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <param name="organization">The name of the organization</param>
+        /// <returns>All the public <see cref="Activity"/>s that are associated with an organization.</returns>
+        IObservable<Activity> GetForAnOrganization(string user, string organization);
+    }
+}
\ No newline at end of file
diff --git a/Octokit.Reactive/Clients/ObservableActivityClient.cs b/Octokit.Reactive/Clients/ObservableActivityClient.cs
new file mode 100644
index 00000000..50cba6dd
--- /dev/null
+++ b/Octokit.Reactive/Clients/ObservableActivityClient.cs
@@ -0,0 +1,155 @@
+using System;
+using Octokit.Reactive.Internal;
+
+namespace Octokit.Reactive
+{
+    public class ObservableActivityClient : IObservableActivityClient
+    {
+        IConnection _connection;
+
+        public ObservableActivityClient(IGitHubClient client)
+        {
+            Ensure.ArgumentNotNull(client, "client");
+
+            _connection = client.Connection;
+        }
+
+        /// <summary>
+        /// Gets all the public events
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events
+        /// </remarks>
+        /// <returns>All the public <see cref="Activity"/>s for the particular user.</returns>
+        public IObservable<Activity> GetAll()
+        {
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.Events());
+        }
+
+        /// <summary>
+        /// Gets all the events for a given repository
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-issue-events-for-a-repository
+        /// </remarks>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="name">The name of the repository</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular repository.</returns>
+        public IObservable<Activity> GetAllForRepository(string owner, string name)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(owner, "owner");
+            Ensure.ArgumentNotNullOrEmptyString(name, "name");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.IssuesEvents(owner, name));
+        }
+
+        /// <summary>
+        /// Gets all the events for a given repository network
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-for-a-network-of-repositories
+        /// </remarks>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="name">The name of the repository</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular repository network.</returns>
+        public IObservable<Activity> GetAllForRepositoryNetwork(string owner, string name)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(owner, "owner");
+            Ensure.ArgumentNotNullOrEmptyString(name, "name");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.NetworkEvents(owner, name));
+        }
+
+        /// <summary>
+        /// Gets all the events for a given organization
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-for-an-organization
+        /// </remarks>
+        /// <param name="organization">The name of the organization</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular organization.</returns>
+        public IObservable<Activity> GetAllForOrganization(string organization)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(organization, "organization");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.OrganizationEvents(organization));
+        }
+
+        /// <summary>
+        /// Gets all the events that have been received by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-that-a-user-has-received
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has received.</returns>
+        public IObservable<Activity> GetUserReceived(string user)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.ReceivedEvents(user));
+        }
+
+        /// <summary>
+        /// Gets all the events that have been received by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-that-a-user-has-received
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has received.</returns>
+        public IObservable<Activity> GetUserReceivedPublic(string user)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.ReceivedEvents(user, true));
+        }
+
+        /// <summary>
+        /// Gets all the events that have been performed by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-performed-by-a-user
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has performed.</returns>
+        public IObservable<Activity> GetUserPerformed(string user)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.PerformedEvents(user));
+        }
+
+        /// <summary>
+        /// Gets all the public events that have been performed by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-performed-by-a-user
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the public <see cref="Activity"/>s that a particular user has performed.</returns>
+        public IObservable<Activity> GetUserPerformedPublic(string user)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.PerformedEvents(user, true));
+        }
+
+        /// <summary>
+        /// Gets all the events that are associated with an organization.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-for-an-organization
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <param name="organization">The name of the organization</param>
+        /// <returns>All the public <see cref="Activity"/>s that are associated with an organization.</returns>
+        public IObservable<Activity> GetForAnOrganization(string user, string organization)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+            Ensure.ArgumentNotNullOrEmptyString(organization, "organization");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.OrganizationEvents(user, organization));
+        }
+    }
+}
diff --git a/Octokit.Reactive/Octokit.Reactive.csproj b/Octokit.Reactive/Octokit.Reactive.csproj
index 4a5d62a0..fe96d9ba 100644
--- a/Octokit.Reactive/Octokit.Reactive.csproj
+++ b/Octokit.Reactive/Octokit.Reactive.csproj
@@ -73,6 +73,8 @@
     <Compile Include="..\SolutionInfo.cs">
       <Link>Properties\SolutionInfo.cs</Link>
     </Compile>
+    <Compile Include="Clients\IObservableActivityClient.cs" />
+    <Compile Include="Clients\ObservableActivityClient.cs" />
     <Compile Include="Clients\ObservableGitDatabaseClient.cs" />
     <Compile Include="Clients\IObservableGitDatabaseClient.cs" />
     <Compile Include="Clients\IObservableTagsClient.cs" />
@@ -135,4 +137,4 @@
   <Target Name="AfterBuild">
   </Target>
   -->
-</Project>
+</Project>
\ No newline at end of file
diff --git a/Octokit.Tests/Clients/ActivitiesClientTests.cs b/Octokit.Tests/Clients/ActivitiesClientTests.cs
index 09ad9341..d16b74a5 100644
--- a/Octokit.Tests/Clients/ActivitiesClientTests.cs
+++ b/Octokit.Tests/Clients/ActivitiesClientTests.cs
@@ -1,6 +1,4 @@
-
-
-using System;
+using System;
 using System.Threading.Tasks;
 using NSubstitute;
 using Octokit.Tests.Helpers;
diff --git a/Octokit/Clients/ActivitiesClient.cs b/Octokit/Clients/ActivitiesClient.cs
index e7e109b9..56a999f4 100644
--- a/Octokit/Clients/ActivitiesClient.cs
+++ b/Octokit/Clients/ActivitiesClient.cs
@@ -1,5 +1,4 @@
-
-using System.Collections.Generic;
+using System.Collections.Generic;
 using System.Threading.Tasks;
 
 namespace Octokit
diff --git a/Octokit/Models/Response/Activity.cs b/Octokit/Models/Response/Activity.cs
index 5b7477dc..62808b8f 100644
--- a/Octokit/Models/Response/Activity.cs
+++ b/Octokit/Models/Response/Activity.cs
@@ -14,7 +14,7 @@ namespace Octokit
         /// Whether the activity event is public or not.
         /// </summary>
         public bool Public { get; set; }
-        
+
         /// <summary>
         /// The repository associated with the activity event.
         /// </summary>