Add support for resolving a service asynchronously (task-based)

Arkane.Zeroconf/IResolvableService.cs

@@ -8,6 +8,8 @@
 #region using
 
 using System.Net ;
+using System.Threading ;
+using System.Threading.Tasks ;
 
 #endregion
 
@@ -30,4 +32,6 @@ public interface IResolvableService : IService
     event ServiceResolvedEventHandler Resolved ;
 
     void Resolve () ;
+
+    Task ResolveAsync (CancellationToken cancellationToken = default) ;
 }

Arkane.Zeroconf/Providers/Bonjour/BrowseService.cs

@@ -12,6 +12,8 @@
 using System.Net ;
 using System.Runtime.InteropServices ;
 using System.Text ;
+using System.Threading ;
+using System.Threading.Tasks ;
 
 #endregion
 
@@ -28,8 +30,8 @@ public BrowseService (string name, string replyDomain, string regtype) : base (n
 
     private Native.DNSServiceQueryRecordReply queryRecordReplyHandler ;
 
-    private Action <bool> resolveAction ;
-    private bool          resolvePending ;
+    private Action <bool, CancellationToken> resolveAction ;
+    private bool                             resolvePending ;
 
     private Native.DNSServiceResolveReply resolveReplyHandler ;
 
@@ -43,7 +45,12 @@ public void Resolve ()
     {
         // If people call this in a ServiceAdded event handler (which they generally do), we need to
         // invoke onto another thread, otherwise we block processing any more results.
-        this.resolveResult = this.resolveAction.BeginInvoke (false, null, null) ;
+        this.resolveResult = ResolveAsync () ;
+    }
+
+    public Task ResolveAsync (CancellationToken cancellationToken = default)
+    {
+        return Task.Run (() => this.resolveAction (false, cancellationToken), cancellationToken) ;
     }
 
     ~BrowseService ()
@@ -60,6 +67,11 @@ private void SetupCallbacks ()
     }
 
     public void Resolve (bool requery)
+    {
+        Resolve (requery, CancellationToken.None) ;
+    }
+
+    public void Resolve (bool requery, CancellationToken cancellationToken)
     {
         if (this.resolvePending)
             return ;
@@ -82,7 +94,7 @@ public void Resolve (bool requery)
         if (error != ServiceError.NoError)
             throw new ServiceErrorException (error) ;
 
-        sdRef.Process () ;
+        sdRef.Process (cancellationToken) ;
     }
 
     public void RefreshTxtRecord ()

Arkane.Zeroconf/Providers/Bonjour/ServiceRef.cs

@@ -8,6 +8,7 @@
 #region using
 
 using System ;
+using System.Threading ;
 
 #endregion
 
@@ -25,8 +26,16 @@ public struct ServiceRef
 
     public void Process ()
     {
-        while (this.ProcessSingle () == ServiceError.NoError)
-        { }
+        Process(CancellationToken.None);
+    }
+
+    public void Process (CancellationToken cancellationToken)
+    {
+        cancellationToken.ThrowIfCancellationRequested();
+        while (this.ProcessSingle() == ServiceError.NoError)
+        {
+            cancellationToken.ThrowIfCancellationRequested();
+        }
     }
 
     public int SocketFD => Native.DNSServiceRefSockFD (this.Raw) ;