From 76e509978f97aaafa29a6e02a7086da607b62a6d Mon Sep 17 00:00:00 2001
From: Haacked <haacked@gmail.com>
Date: Thu, 3 Oct 2013 16:02:53 -0700
Subject: [PATCH] Add Observable GetEmails method

---
 Octokit.Reactive/Clients/ObservableUsersClient.cs | 15 ++++++++++-----
 Octokit.Reactive/IObservableUsersClient.cs        |  9 +++++++--
 2 files changed, 17 insertions(+), 7 deletions(-)

diff --git a/Octokit.Reactive/Clients/ObservableUsersClient.cs b/Octokit.Reactive/Clients/ObservableUsersClient.cs
index cefb3dcb..e14c2f6c 100644
--- a/Octokit.Reactive/Clients/ObservableUsersClient.cs
+++ b/Octokit.Reactive/Clients/ObservableUsersClient.cs
@@ -5,32 +5,37 @@ namespace Octokit.Reactive.Clients
 {
     public class ObservableUsersClient : IObservableUsersClient
     {
-        readonly IUsersClient client;
+        readonly IUsersClient _client;
 
         public ObservableUsersClient(IUsersClient client)
         {
             Ensure.ArgumentNotNull(client, "client");
 
-            this.client = client;
+            this._client = client;
         }
 
         public IObservable<User> Get(string login)
         {
             Ensure.ArgumentNotNull(login, "login");
 
-            return client.Get(login).ToObservable();
+            return _client.Get(login).ToObservable();
         }
 
         public IObservable<User> Current()
         {
-            return client.Current().ToObservable();
+            return _client.Current().ToObservable();
         }
 
         public IObservable<User> Update(UserUpdate user)
         {
             Ensure.ArgumentNotNull(user, "user");
 
-            return client.Update(user).ToObservable();
+            return _client.Update(user).ToObservable();
+        }
+
+        public IObservable<IReadOnlyList<EmailAddress>> GetEmails()
+        {
+            return _client.GetEmails().ToObservable();
         }
     }
 }
diff --git a/Octokit.Reactive/IObservableUsersClient.cs b/Octokit.Reactive/IObservableUsersClient.cs
index 8440c1ce..96d56799 100644
--- a/Octokit.Reactive/IObservableUsersClient.cs
+++ b/Octokit.Reactive/IObservableUsersClient.cs
@@ -1,7 +1,5 @@
 using System;
-using System.Collections.Generic;
 using System.Diagnostics.CodeAnalysis;
-using System.Threading.Tasks;
 
 namespace Octokit.Reactive
 {
@@ -29,5 +27,12 @@ namespace Octokit.Reactive
         /// <exception cref="AuthorizationException">Thrown if the client is not authenticated.</exception>
         /// <returns>A <see cref="User"/></returns>
         IObservable<User> Update(UserUpdate user);
+
+        /// <summary>
+        /// Returns emails for the current user.
+        /// </summary>
+        /// <returns></returns>
+        [SuppressMessage("Microsoft.Design", "CA1024:UsePropertiesWhereAppropriate")]
+        IObservable<IReadOnlyList<EmailAddress>> GetEmails();
     }
 }