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

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

namespace Octokit.Reactive.Clients
{
    public class ObservableOrganizationsClient : IObservableOrganizationsClient
    {
        readonly IOrganizationsClient _client;

        public ObservableOrganizationsClient(IOrganizationsClient client)
        {
            Ensure.ArgumentNotNull(client, "client");

            _client = client;
        }

        public IObservable<Organization> Get(string org)
        {
            Ensure.ArgumentNotNullOrEmptyString(org, "org");

            return _client.Get(org).ToObservable();
        }

        public IObservable<IReadOnlyCollection<Organization>> GetAllForCurrent()
        {
            return _client.GetAllForCurrent().ToObservable();
        }

        public IObservable<IReadOnlyCollection<Organization>> GetAll(string user)
        {
            Ensure.ArgumentNotNullOrEmptyString(user, "user");

            return _client.GetAll(user).ToObservable();
        }
    }
}