From 13dbfea5837a2a96ac4b4b100f72bb5fbc1e209c Mon Sep 17 00:00:00 2001
From: half-ogre <nemo@half-ogre.com>
Date: Tue, 8 Oct 2013 09:43:52 -0700
Subject: [PATCH] add reactive counter-part

---
 .../Clients/ObservableRepositoriesClient.cs        | 14 ++++++++++++++
 Octokit.Reactive/IObservableRepositoriesClient.cs  |  7 +++++++
 2 files changed, 21 insertions(+)

diff --git a/Octokit.Reactive/Clients/ObservableRepositoriesClient.cs b/Octokit.Reactive/Clients/ObservableRepositoriesClient.cs
index 6084e1c7..1511259c 100644
--- a/Octokit.Reactive/Clients/ObservableRepositoriesClient.cs
+++ b/Octokit.Reactive/Clients/ObservableRepositoriesClient.cs
@@ -15,6 +15,20 @@ namespace Octokit.Reactive.Clients
             _client = client;
         }
 
+        /// <summary>
+        /// Creates a new repository for the current user.
+        /// </summary>
+        /// <param name="newRepository">A <see cref="NewRepository"/> instance describing the new repository to create</param>
+        /// <returns>An <see cref="IObservable{Repository}"/> instance for the created repository</returns>
+        public IObservable<Repository> Create(NewRepository newRepository)
+        {
+            Ensure.ArgumentNotNull(newRepository, "newRepository");
+            if (string.IsNullOrEmpty(newRepository.Name))
+                throw new ArgumentException("The new repository's name must not be null.");
+
+            return _client.Create(newRepository).ToObservable();
+        }
+
         public IObservable<Repository> Get(string owner, string name)
         {
             Ensure.ArgumentNotNullOrEmptyString(owner, "owner");
diff --git a/Octokit.Reactive/IObservableRepositoriesClient.cs b/Octokit.Reactive/IObservableRepositoriesClient.cs
index bc8a1a32..2dc6bb33 100644
--- a/Octokit.Reactive/IObservableRepositoriesClient.cs
+++ b/Octokit.Reactive/IObservableRepositoriesClient.cs
@@ -6,6 +6,13 @@ namespace Octokit.Reactive
 {
     public interface IObservableRepositoriesClient
     {
+        /// <summary>
+        /// Creates a new repository for the current user.
+        /// </summary>
+        /// <param name="newRepository">A <see cref="NewRepository"/> instance describing the new repository to create</param>
+        /// <returns>An <see cref="IObservable{Repository}"/> instance for the created repository</returns>
+        IObservable<Repository> Create(NewRepository newRepository);
+        
         /// <summary>
         /// Retrieves the <see cref="Repository"/> for the specified owner and name.
         /// </summary>