add AdxAsync

DaveSkender · Nov 9, 2023 · 42d4d7f · 42d4d7f
1 parent ca10bc9
commit 42d4d7f
Show file tree

Hide file tree

Showing 3 changed files with 59 additions and 0 deletions.
diff --git a/src/a-d/Adx/Adx.Api.cs b/src/a-d/Adx/Adx.Api.cs
@@ -12,4 +12,13 @@ public static IEnumerable<AdxResult> GetAdx<TQuote>(
         where TQuote : IQuote => quotes
             .ToQuoteD()
             .CalcAdx(lookbackPeriods);
+
+    // TASK, from TQuote
+    /// <include file='./info.xml' path='info/*' />
+    ///
+    public static Task<IEnumerable<AdxResult>> GetAdxAsync<TQuote>(
+        this IEnumerable<TQuote> quotes,
+        int lookbackPeriods = 14)
+        where TQuote : IQuote => Task.Run(() => quotes
+            .GetAdx(lookbackPeriods));
 }
diff --git a/tests/indicators/a-d/Adx/Adx.Tests.cs b/tests/indicators/a-d/Adx/Adx.Tests.cs
@@ -48,6 +48,31 @@ public void Standard()
         Assert.AreEqual(34.2987, r501.Adx.Round(4));
     }
 
+    [TestMethod]
+    public async Task Async()
+    {
+        List<AdxResult> ogList = quotes
+            .GetAdx(14)
+            .ToList();
+
+        IEnumerable<AdxResult> results = await quotes
+            .GetAdxAsync(14)
+            .ConfigureAwait(false);
+
+        List<AdxResult> rsList = results.ToList();
+
+        Assert.AreEqual(ogList.Count, rsList.Count);
+
+        for (int i = 0; i < rsList.Count; i++)
+        {
+            AdxResult o = ogList[i];
+            AdxResult r = rsList[i];
+
+            Assert.AreEqual(o.Date, r.Date);
+            Assert.AreEqual(o.Adx, r.Adx);
+        }
+    }
+
     [TestMethod]
     public void Chainor()
     {

diff --git a/tests/performance/Perf.Indicators.cs b/tests/performance/Perf.Indicators.cs
@@ -46,6 +46,31 @@ public static void SetupCompare()
     [Benchmark]
     public object GetAdx() => h.GetAdx();
 
+    [Benchmark]
+    public async Task<object> GetAdxAsync()
+        => await h.GetAdxAsync()
+            .ConfigureAwait(false);
+
+    [Benchmark]
+    public async Task<object> GetAdxAsyncExtension()
+        => await h.GetAdx()
+            .AsAsync()
+            .ConfigureAwait(false);
+
+    [Benchmark]
+    public async Task<object> GetAdx3asyncExt()
+    {
+        Task<IEnumerable<AdxResult>> taskA = h.GetAdx(13).AsAsync();
+        Task<IEnumerable<AdxResult>> taskB = h.GetAdx(14).AsAsync();
+        Task<IEnumerable<AdxResult>> taskC = h.GetAdx(15).AsAsync();
+
+        await taskA.ConfigureAwait(false);
+        await taskB.ConfigureAwait(false);
+        await taskC.ConfigureAwait(false);
+
+        return "foo";
+    }
+
     [Benchmark]
     public object GetAlligator() => h.GetAlligator();