diff --git a/Octokit.Reactive/Helpers/ConnectionExtensions.cs b/Octokit.Reactive/Helpers/ConnectionExtensions.cs index ff32906e..f4d3daf2 100644 --- a/Octokit.Reactive/Helpers/ConnectionExtensions.cs +++ b/Octokit.Reactive/Helpers/ConnectionExtensions.cs @@ -5,9 +5,19 @@ using System.Reactive.Threading.Tasks; namespace Octokit.Reactive.Internal { - internal static class ConnectionExtensions + public static class ConnectionExtensions { - public static IObservable GetAndFlattenAllPages(this IConnection connection, Uri url, IDictionary parameters = null, string accepts = null) + public static IObservable GetAndFlattenAllPages(this IConnection connection, Uri url) + { + return GetPages(url, null, (pageUrl, pageParams) => connection.Get>(pageUrl, null, null).ToObservable()); + } + + public static IObservable GetAndFlattenAllPages(this IConnection connection, Uri url, IDictionary parameters) + { + return GetPages(url, parameters, (pageUrl, pageParams) => connection.Get>(pageUrl, pageParams, null).ToObservable()); + } + + public static IObservable GetAndFlattenAllPages(this IConnection connection, Uri url, IDictionary parameters, string accepts) { return GetPages(url, parameters, (pageUrl, pageParams) => connection.Get>(pageUrl, pageParams, accepts).ToObservable()); }