Task-ize ConnectionManagerExtensions.

`ConnectionManagerExtensions` methods were returning `IObservables` but only returning a single value. Convert them to return `Task`s so they can be used in Team Explorer etc.

Author: grokys

src/GitHub.Exports.Reactive/Extensions/ConnectionManagerExtensions.cs

@@ -1,66 +1,13 @@
 using System;
-using System.Linq;
-using System.Reactive.Linq;
-using System.Reactive.Threading.Tasks;
 using System.Threading.Tasks;
 using GitHub.Factories;
 using GitHub.Models;
-using GitHub.Primitives;
 using GitHub.Services;
 
 namespace GitHub.Extensions
 {
     public static class ConnectionManagerExtensions
     {
-        public static IObservable<bool> IsLoggedIn(this IConnectionManager cm)
-        {
-            Guard.ArgumentNotNull(cm, nameof(cm));
-
-            return Observable.FromAsync(async () =>
-            {
-                var connections = await cm.GetLoadedConnections();
-                return connections.Any(x => x.ConnectionError == null);
-            });
-        }
-
-        public static IObservable<bool> IsLoggedIn(this IConnectionManager cm, HostAddress address)
-        {
-            Guard.ArgumentNotNull(cm, nameof(cm));
-            Guard.ArgumentNotNull(address, nameof(address));
-
-            return Observable.FromAsync(async () =>
-            {
-                var connections = await cm.GetLoadedConnections();
-                return connections.Any(x => x.HostAddress == address && x.ConnectionError == null);
-            });
-        }
-
-        public static IObservable<bool> IsLoggedIn(this IConnection connection)
-        {
-            Guard.ArgumentNotNull(connection, nameof(connection));
-
-            return Observable.Return(connection?.IsLoggedIn ?? false);
-        }
-
-        public static IObservable<IConnection> GetConnection(this IConnectionManager cm, HostAddress address)
-        {
-            Guard.ArgumentNotNull(cm, nameof(cm));
-            Guard.ArgumentNotNull(address, nameof(address));
-
-            return cm.GetLoadedConnections()
-                .ToObservable()
-                .Select(x => x.FirstOrDefault(y => y.HostAddress == address));
-        }
-
-        public static IObservable<IConnection> GetLoggedInConnections(this IConnectionManager cm)
-        {
-            Guard.ArgumentNotNull(cm, nameof(cm));
-
-            return cm.GetLoadedConnections()
-                .ToObservable()
-                .Select(x => x.FirstOrDefault(y => y.IsLoggedIn));
-        }
-
         public static async Task<IModelService> GetModelService(
             this IConnectionManager cm,
             ILocalRepositoryModel repository,
@@ -69,12 +16,5 @@ public static async Task<IModelService> GetModelService(
             var connection = await cm.LookupConnection(repository);
             return connection != null ? await factory.CreateAsync(connection) : null;
         }
-
-        public static IObservable<IConnection> LookupConnection(this IConnectionManager cm, ILocalRepositoryModel repository)
-        {
-            return Observable.Return(repository?.CloneUrl != null
-                ? cm.Connections.FirstOrDefault(c => c.HostAddress.Equals(HostAddress.Create(repository.CloneUrl)))
-                : null);
-        }
     }
 }

src/GitHub.Exports/Extensions/ConnectionManagerExtensions.cs

@@ -0,0 +1,48 @@
+using System;
+using System.Linq;
+using System.Threading.Tasks;
+using GitHub.Models;
+using GitHub.Primitives;
+using GitHub.Services;
+
+namespace GitHub.Extensions
+{
+    public static class ConnectionManagerExtensions
+    {
+        public static async Task<bool> IsLoggedIn(this IConnectionManager cm)
+        {
+            Guard.ArgumentNotNull(cm, nameof(cm));
+
+            var connections = await cm.GetLoadedConnections();
+            return connections.Any(x => x.ConnectionError == null);
+        }
+
+        public static async Task<bool> IsLoggedIn(this IConnectionManager cm, HostAddress address)
+        {
+            Guard.ArgumentNotNull(cm, nameof(cm));
+            Guard.ArgumentNotNull(address, nameof(address));
+
+            var connections = await cm.GetLoadedConnections();
+            return connections.Any(x => x.HostAddress == address && x.ConnectionError == null);
+        }
+
+        public static async Task<IConnection> GetLoggedInConnections(this IConnectionManager cm)
+        {
+            Guard.ArgumentNotNull(cm, nameof(cm));
+
+            var connections = await cm.GetLoadedConnections();
+            return connections.FirstOrDefault(x => x.IsLoggedIn);
+        }
+
+        public static Task<IConnection> LookupConnection(this IConnectionManager cm, ILocalRepositoryModel repository)
+        {
+            if (repository?.CloneUrl != null)
+            {
+                var hostAddress = HostAddress.Create(repository.CloneUrl);
+                return cm.GetConnection(hostAddress);
+            }
+
+            return null;
+        }
+    }
+}