Add reactive notifications client

Octokit.Reactive/Clients/ObservableNotificationsClient.cs

@@ -0,0 +1,37 @@
+using System;
+using Octokit.Reactive.Internal;
+
+namespace Octokit.Reactive.Clients
+{
+    public class ObservableNotificationsClient : IObservableNotificationsClient
+    {
+        readonly IConnection _connection;
+
+        public ObservableNotificationsClient(IGitHubClient client)
+        {
+            Ensure.ArgumentNotNull(client, "client");
+
+            _connection = client.Connection;
+        }
+
+        /// <summary>
+        /// Retrieves all of the <see cref="Notification"/>s for the current user.
+        /// </summary>
+        /// <exception cref="AuthorizationException">Thrown if the client is not authenticated.</exception>
+        /// <returns>A <see cref="IObservable{Notification}"/> of <see cref="Notification"/>.</returns>
+        public IObservable<Notification> GetAllForCurrent()
+        {
+            return _connection.GetAndFlattenAllPages<Notification>(ApiUrls.Notifications());
+        }
+
+        /// <summary>
+        /// Retrieves all of the <see cref="Notification"/>s for the current user specific to the specified repository.
+        /// </summary>
+        /// <exception cref="AuthorizationException">Thrown if the client is not authenticated.</exception>
+        /// <returns>A <see cref="IObservable{Notification}"/> of <see cref="Notification"/>.</returns>
+        public IObservable<Notification> GetAllForRepository(string owner, string name)
+        {
+            return _connection.GetAndFlattenAllPages<Notification>(ApiUrls.Notifications(owner, name));
+        }
+    }
+}