Merge pull request #476 from AndreyG/RdTask.GetAwaiter

implement RdTask.GetAwaiter

Author: Iliya-usov

rd-net/RdFramework/Tasks/RdTaskEx.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Runtime.CompilerServices;
 using System.Threading;
 using System.Threading.Tasks;
 using JetBrains.Annotations;
@@ -121,5 +122,27 @@ public static Task<T> AsTask<T>(this IRdTask<T> task)
       });
       return tcs.Task;
     }
+    
+    [PublicAPI]
+    public static RdTaskAwaiter<T> GetAwaiter<T>(this IRdTask<T> task) => new(task.Result);
+    
+    public readonly struct RdTaskAwaiter<T> : INotifyCompletion
+    {
+      private readonly IReadonlyProperty<RdTaskResult<T>> myResult;
+
+      internal RdTaskAwaiter(IReadonlyProperty<RdTaskResult<T>> result)
+      {
+        myResult = result;
+      }
+
+      public bool IsCompleted => myResult.Maybe.HasValue;
+
+      public T GetResult() => myResult.Value.Unwrap();
+
+      public void OnCompleted(Action continuation)
+      {
+        myResult.Change.AdviseOnce(Lifetime.Eternal, _ => continuation());
+      }
+    }
   }
 }

rd-net/Test.RdFramework/AsyncRdTaskTest.cs

@@ -20,7 +20,24 @@ protected override IScheduler CreateScheduler(bool isServer)
   }
 
   [Test]
-  public void BindableRdCallListTest()
+  public void BindableRdCallListUseSystemTaskTest()
+  {
+    BindableRdCallListTest(TaskKind.System);
+  }
+
+  [Test]
+  public void BindableRdCallListUseRdTaskTest()
+  {
+    BindableRdCallListTest(TaskKind.Rd);
+  }
+
+  private enum TaskKind
+  {
+    System,
+    Rd,
+  }
+
+  private void BindableRdCallListTest(TaskKind taskKind)
   {  
     ClientWire.AutoTransmitMode = true;
     ServerWire.AutoTransmitMode = true;
@@ -52,7 +69,12 @@ public void BindableRdCallListTest()
       {
         BindToClient(lifetime, callsite, entity_id);
 
-        var list = await callsite.Start(lifetime, Unit.Instance).AsTask();
+        var list = taskKind switch
+        {
+          TaskKind.System => await callsite.Start(lifetime, Unit.Instance).AsTask(),
+          TaskKind.Rd     => await callsite.Start(lifetime, Unit.Instance),
+          _ => throw new ArgumentOutOfRangeException(nameof(taskKind), taskKind, null)
+        };
         var count = 0;
 
         list.View(lifetime, (lt, index, value) =>