octokit.net/Octokit.Reactive/Clients/ObservableRepoCollaboratorsClient.cs

using System;
using System.Collections.Generic;
using System.Reactive;
using System.Reactive.Threading.Tasks;
using Octokit.Reactive.Internal;

namespace Octokit.Reactive
{
    public class ObservableRepoCollaboratorsClient : IObservableRepoCollaboratorsClient
    {
        readonly IRepoCollaboratorsClient _client;
        readonly IConnection _connection;

        public ObservableRepoCollaboratorsClient(IGitHubClient client)
        {
            Ensure.ArgumentNotNull(client, "client");

            _client = client.Repository.RepoCollaborators;
            _connection = client.Connection;
        }

        /// <summary>
        /// Gets all the available collaborators on this repo.
        /// </summary>
        /// <param name="owner">The owner of the repository</param>
        /// <param name="repo">The name of the repository</param>
        /// <returns></returns>
        public IObservable<User> GetAll(string owner, string repo)
        {
            Ensure.ArgumentNotNull(owner, "owner");
            Ensure.ArgumentNotNull(repo, "name");
            var endpoint = ApiUrls.RepoCollaborators(owner, repo);
            return _connection.GetAndFlattenAllPages<User>(endpoint);
        }

        /// <summary>
        /// Checks to see if a user is an assignee for a repository.
        /// </summary>
        /// <param name="owner">The owner of the repository</param>
        /// <param name="repo">The name of the repository</param>
        /// <param name="user">Username of the prospective collaborator</param>
        /// <returns></returns>
        public IObservable<bool> IsCollaborator(string owner, string repo, string user)
        {
            return _client.IsCollaborator(owner, repo, user).ToObservable();
        }

        /// <summary>
        /// Adds a user as a collaborator to a repository.
        /// </summary>
        /// <param name="owner">The owner of the repository</param>
        /// <param name="repo">The name of the repository</param>
        /// <param name="user">Username of the prospective collaborator</param>
        /// <returns></returns>
        public IObservable<Unit> Add(string owner, string repo, string user)
        {
            return _client.Add(owner, repo, user).ToObservable();
        }

        /// <summary>
        /// Removes a user as a collaborator for a repository.
        /// </summary>
        /// <param name="owner">The owner of the repository</param>
        /// <param name="repo">The name of the repository</param>
        /// <param name="user">Username of the prospective collaborator</param>
        /// <returns></returns>
        public IObservable<Unit> Delete(string owner, string repo, string user)
        {
            return _client.Delete(owner, repo, user).ToObservable();
        }
    }
}