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 Get(string login) { Ensure.ArgumentNotNull(login, "login"); - return client.Get(login).ToObservable(); + return _client.Get(login).ToObservable(); } public IObservable Current() { - return client.Current().ToObservable(); + return _client.Current().ToObservable(); } public IObservable Update(UserUpdate user) { Ensure.ArgumentNotNull(user, "user"); - return client.Update(user).ToObservable(); + return _client.Update(user).ToObservable(); + } + + public IObservable> 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 /// Thrown if the client is not authenticated. /// A IObservable Update(UserUpdate user); + + /// + /// Returns emails for the current user. + /// + /// + [SuppressMessage("Microsoft.Design", "CA1024:UsePropertiesWhereAppropriate")] + IObservable> GetEmails(); } }