DaveSkender · DaveSkender · Dec 1, 2024 · Nov 11, 2024 · Nov 12, 2024 · Nov 16, 2024
diff --git a/src/_common/Incrementals/IBufferList.cs → src/_common/BufferLists/IBufferList.cs b/src/_common/Incrementals/IBufferList.cs → src/_common/BufferLists/IBufferList.cs
diff --git a/src/_common/Observables/StreamHub.Utilities.cs b/src/_common/Observables/StreamHub.Utilities.cs
@@ -19,7 +19,7 @@ internal static bool TryFindIndex<T>(
         out int index)
         where T : ISeries
     {
-        index = cache.GetIndex(timestamp, false);
+        index = cache.IndexOf(timestamp, false);
         return index != -1;
     }
 
@@ -32,7 +32,7 @@ internal static bool TryFindIndex<T>(
     /// <param name="throwOnFail">Throw exception when item is not found.</param>
     /// <returns>Index position.</returns>
     /// <exception cref="ArgumentException">When item is not found (should never happen).</exception>
-    internal static int GetIndex<T>(
+    internal static int IndexOf<T>(
         this IReadOnlyList<T> cache,
         T cachedItem,
         bool throwOnFail)
@@ -105,15 +105,15 @@ internal static int GetIndex<T>(
     /// <remarks>
     /// Only use this when you are looking for a point in time
     /// without a matching item for context. In most cases
-    /// <see cref="GetIndex{T}(IReadOnlyList{T},T,bool)"/> is more appropriate.
+    /// <see cref="IndexOf{T}(IReadOnlyList{T},T,bool)"/> is more appropriate.
     /// </remarks>
     /// <typeparam name="T">Type of the items in the cache, must implement ISeries.</typeparam>
     /// <param name="cache">The cache to search.</param>
     /// <param name="timestamp">Timestamp of cached item.</param>
     /// <param name="throwOnFail">Throw exception when timestamp is not found.</param>
     /// <returns>Index position.</returns>
     /// <exception cref="ArgumentException">When timestamp is not found (should never happen).</exception>
-    internal static int GetIndex<T>(
+    internal static int IndexOf<T>(
         this IReadOnlyList<T> cache,
         DateTime timestamp,
         bool throwOnFail)
@@ -154,13 +154,13 @@ internal static int GetIndex<T>(
     /// <remarks>
     /// Only use this when you are looking for a point in time
     /// without a matching item for context. In most cases
-    /// <see cref="GetIndex{T}(IReadOnlyList{T},T,bool)"/> is more appropriate.
+    /// <see cref="IndexOf{T}(IReadOnlyList{T},T,bool)"/> is more appropriate.
     /// </remarks>
     /// <typeparam name="T">Type of the items in the cache, must implement ISeries.</typeparam>
     /// <param name="cache">The cache to search.</param>
     /// <param name="timestamp">Timestamp of cached item.</param>
     /// <returns>First index position or -1 if not found.</returns>
-    internal static int GetIndexGte<T>(
+    internal static int IndexGte<T>(
         this IReadOnlyList<T> cache,
         DateTime timestamp)
         where T : ISeries

diff --git a/src/_common/Observables/StreamHub.cs b/src/_common/Observables/StreamHub.cs
@@ -358,7 +358,7 @@ public void Rebuild(DateTime fromTimestamp)
         RemoveRange(fromTimestamp, notify: false);
 
         // get provider position
-        int provIndex = ProviderCache.GetIndexGte(fromTimestamp);
+        int provIndex = ProviderCache.IndexGte(fromTimestamp);
 
         // rebuild
         if (provIndex >= 0)

diff --git a/src/_common/Quotes/Quote.StreamHub.cs b/src/_common/Quotes/Quote.StreamHub.cs
@@ -47,7 +47,7 @@ protected override (TQuote result, int index)
         ToIndicator(TQuote item, int? indexHint)
     {
         int index = indexHint
-            ?? Cache.GetIndexGte(item.Timestamp);
+            ?? Cache.IndexGte(item.Timestamp);
 
         return (item, index == -1 ? Cache.Count : index);
     }

diff --git a/src/a-d/Adl/Adl.StreamHub.cs b/src/a-d/Adl/Adl.StreamHub.cs
@@ -38,7 +38,7 @@ internal AdlHub(IQuoteProvider<TIn> provider)
     protected override (AdlResult result, int index)
         ToIndicator(TIn item, int? indexHint)
     {
-        int i = indexHint ?? ProviderCache.GetIndex(item, true);
+        int i = indexHint ?? ProviderCache.IndexOf(item, true);
 
         // candidate result
         AdlResult r = Adl.Increment(

diff --git a/src/a-d/Alligator/Alligator.StreamHub.cs b/src/a-d/Alligator/Alligator.StreamHub.cs
@@ -165,7 +165,7 @@ protected override (AlligatorResult result, int index)
         double lips = double.NaN;
         double teeth = double.NaN;
 
-        int i = indexHint ?? ProviderCache.GetIndex(item, true);
+        int i = indexHint ?? ProviderCache.IndexOf(item, true);
 
         // calculate alligator's jaw, when in range
         if (i >= JawPeriods + JawOffset - 1)

diff --git a/src/a-d/Atr/Atr.StreamHub.cs b/src/a-d/Atr/Atr.StreamHub.cs
@@ -72,7 +72,7 @@ internal AtrHub(IQuoteProvider<TIn> provider,
     protected override (AtrResult result, int index)
         ToIndicator(TIn item, int? indexHint)
     {
-        int i = indexHint ?? ProviderCache.GetIndex(item, true);
+        int i = indexHint ?? ProviderCache.IndexOf(item, true);
 
         // skip incalculable periods
         if (i == 0)

diff --git a/src/a-d/AtrStop/AtrStop.StreamHub.cs b/src/a-d/AtrStop/AtrStop.StreamHub.cs
@@ -116,7 +116,7 @@ protected override (AtrStopResult result, int index)
     {
         // reminder: should only process "new" instructions
 
-        int i = indexHint ?? ProviderCache.GetIndex(item, true);
+        int i = indexHint ?? ProviderCache.IndexOf(item, true);
 
         // handle warmup periods
         if (i < LookbackPeriods)
@@ -232,7 +232,7 @@ protected override (AtrStopResult result, int index)
     /// <inheritdoc/>
     protected override void RollbackState(DateTime timestamp)
     {
-        int i = ProviderCache.GetIndexGte(timestamp);
+        int i = ProviderCache.IndexGte(timestamp);
 
         // restore prior stop point
         if (i > LookbackPeriods)

diff --git a/src/e-k/Ema/Ema.StreamHub.cs b/src/e-k/Ema/Ema.StreamHub.cs
@@ -78,7 +78,7 @@ internal EmaHub(
     protected override (EmaResult result, int index)
         ToIndicator(TIn item, int? indexHint)
     {
-        int i = indexHint ?? ProviderCache.GetIndex(item, true);
+        int i = indexHint ?? ProviderCache.IndexOf(item, true);
 
         double ema = i >= LookbackPeriods - 1
             ? Cache[i - 1].Ema is not null

diff --git a/src/m-r/Renko/Renko.StreamHub.cs b/src/m-r/Renko/Renko.StreamHub.cs
@@ -183,7 +183,7 @@ int newBrickQty
             decimal sumV = 0;  // cumulative
 
             // by aggregating provider cache range
-            int lastBrickIndex = ProviderCache.GetIndex(lastBrick.Timestamp, true);
+            int lastBrickIndex = ProviderCache.IndexOf(lastBrick.Timestamp, true);
 
             for (int w = lastBrickIndex + 1; w <= providerIndex; w++)
             {

diff --git a/src/s-z/Sma/Sma.StreamHub.cs b/src/s-z/Sma/Sma.StreamHub.cs
@@ -78,7 +78,7 @@ internal SmaHub(
     protected override (SmaResult result, int index)
         ToIndicator(TIn item, int? indexHint)
     {
-        int i = indexHint ?? ProviderCache.GetIndex(item, true);
+        int i = indexHint ?? ProviderCache.IndexOf(item, true);
 
         // candidate result
         SmaResult r = new(

diff --git a/src/s-z/Tr/Tr.StreamHub.cs b/src/s-z/Tr/Tr.StreamHub.cs
@@ -51,7 +51,7 @@ internal TrHub(IQuoteProvider<TIn> provider)
     protected override (TrResult result, int index)
         ToIndicator(TIn item, int? indexHint)
     {
-        int i = indexHint ?? ProviderCache.GetIndex(item, true);
+        int i = indexHint ?? ProviderCache.IndexOf(item, true);
 
         // skip first period
         if (i == 0)

diff --git a/...StreamHub.Utilities.StaticSeries.Tests.cs → .../Observables/StreamHub.Utilities.Tests.cs b/...StreamHub.Utilities.StaticSeries.Tests.cs → .../Observables/StreamHub.Utilities.Tests.cs
@@ -110,8 +110,8 @@ public void GetIndex()
         // find position of quote
         Quote q = quotesList[4];
 
-        int itemIndexEx = provider.Cache.GetIndex(q, true);
-        int timeIndexEx = provider.Cache.GetIndex(q.Timestamp, true);
+        int itemIndexEx = provider.Cache.IndexOf(q, true);
+        int timeIndexEx = provider.Cache.IndexOf(q.Timestamp, true);
 
         // assert: same index
         itemIndexEx.Should().Be(4);
@@ -121,22 +121,22 @@ public void GetIndex()
         Quote o = Quotes[10];
 
         Assert.ThrowsException<ArgumentException>(() => {
-            provider.Cache.GetIndex(o, true);
+            provider.Cache.IndexOf(o, true);
         });
 
         Assert.ThrowsException<ArgumentException>(() => {
-            provider.Cache.GetIndex(o.Timestamp, true);
+            provider.Cache.IndexOf(o.Timestamp, true);
         });
 
         // out of range (no exceptions)
-        int itemIndexNo = provider.Cache.GetIndex(o, false);
-        int timeIndexNo = provider.Cache.GetIndex(o.Timestamp, false);
+        int itemIndexNo = provider.Cache.IndexOf(o, false);
+        int timeIndexNo = provider.Cache.IndexOf(o.Timestamp, false);
 
         itemIndexNo.Should().Be(-1);
         timeIndexNo.Should().Be(-1);
 
-        int timeInsertOut = provider.Cache.GetIndexGte(o.Timestamp);
-        int timeInsertIn = provider.Cache.GetIndexGte(quotesList[2].Timestamp);
+        int timeInsertOut = provider.Cache.IndexGte(o.Timestamp);
+        int timeInsertIn = provider.Cache.IndexGte(quotesList[2].Timestamp);
 
         timeInsertOut.Should().Be(-1);
         timeInsertIn.Should().Be(2);