build fix.

mikasoukhov · mikasoukhov · commit f43a3fda8b2f · 2025-11-22T21:26:57.000+03:00
diff --git a/Algo/CollectionSecurityProvider.cs b/Algo/CollectionSecurityProvider.cs
@@ -1,7 +1,5 @@
 namespace StockSharp.Algo;
 
-using Ecng.Linq;
-
 /// <summary>
 /// The supplier of information on instruments, getting data from the collection.
 /// </summary>
@@ -56,7 +54,7 @@ public ValueTask<Security> LookupByIdAsync(SecurityId id, CancellationToken canc
 
 	/// <inheritdoc />
 	public IAsyncEnumerable<Security> LookupAsync(SecurityLookupMessage criteria, CancellationToken cancellationToken)
-		=> _inner.SyncGet(d => d.Values.Filter(criteria)).ToAsyncEnumerable2(cancellationToken);
+		=> _inner.SyncGet(d => d.Values.Filter(criteria)).ToAsyncEnumerable();
 
 	async ValueTask<SecurityMessage> ISecurityMessageProvider.LookupMessageByIdAsync(SecurityId id, CancellationToken cancellationToken)
 		=> (await LookupByIdAsync(id, cancellationToken))?.ToMessage();
diff --git a/Algo/FilterableSecurityProvider.cs b/Algo/FilterableSecurityProvider.cs
@@ -1,7 +1,5 @@
 namespace StockSharp.Algo;
 
-using Ecng.Linq;
-
 /// <summary>
 /// Provider of information about instruments supporting search using <see cref="SecurityTrie"/>.
 /// </summary>
@@ -59,7 +57,7 @@ public IAsyncEnumerable<Security> LookupAsync(SecurityLookupMessage criteria, Ca
 		if (!secId.IsEmpty())
 			securities = securities.Where(s => s.Id.EqualsIgnoreCase(secId));
 
-		return securities.Filter(criteria).TryLimitByCount(criteria).ToAsyncEnumerable2(cancellationToken);
+		return securities.Filter(criteria).TryLimitByCount(criteria).ToAsyncEnumerable();
 	}
 
 	async ValueTask<SecurityMessage> ISecurityMessageProvider.LookupMessageByIdAsync(SecurityId id, CancellationToken cancellationToken)
diff --git a/Algo/Storages/Csv/CsvEntityRegistry.cs b/Algo/Storages/Csv/CsvEntityRegistry.cs
@@ -1,7 +1,5 @@
 namespace StockSharp.Algo.Storages.Csv;
 
-using Ecng.Linq;
-
 /// <summary>
 /// The CSV storage of trading objects.
 /// </summary>
@@ -137,7 +135,7 @@ IAsyncEnumerable<Security> ISecurityProvider.LookupAsync(SecurityLookupMessage c
 				arr = security == null ? [] : [security];
 			}
 
-			return arr.ToAsyncEnumerable2(cancellationToken);
+			return arr.ToAsyncEnumerable();
 		}
 
 		ValueTask<SecurityMessage> ISecurityMessageProvider.LookupMessageByIdAsync(SecurityId id, CancellationToken cancellationToken)
diff --git a/Algo/Storages/ISecurityStorage.cs b/Algo/Storages/ISecurityStorage.cs
@@ -1,7 +1,5 @@
 namespace StockSharp.Algo.Storages;
 
-using Ecng.Linq;
-
 /// <summary>
 /// The interface for access to the storage of information on instruments.
 /// </summary>
@@ -154,7 +152,7 @@ public ValueTask DeleteRangeAsync(IEnumerable<Security> securities, Cancellation
 
 	/// <inheritdoc />
 	public IAsyncEnumerable<Security> LookupAsync(SecurityLookupMessage criteria, CancellationToken cancellationToken)
-		=> _inner.SyncGet(d => d.Values.Filter(criteria).ToArray()).Concat(_underlying.Lookup(criteria)).Distinct().ToAsyncEnumerable2(cancellationToken);
+		=> _inner.SyncGet(d => d.Values.Filter(criteria).ToArray()).Concat(_underlying.Lookup(criteria)).Distinct().ToAsyncEnumerable();
 
 	/// <inheritdoc />
 	public ValueTask<Security> LookupByIdAsync(SecurityId id, CancellationToken cancellationToken)
diff --git a/Algo/Storages/InMemoryMarketDataStorage.cs b/Algo/Storages/InMemoryMarketDataStorage.cs
@@ -1,7 +1,5 @@
 namespace StockSharp.Algo.Storages;
 
-using Ecng.Linq;
-
 /// <summary>
 /// The storage, generating data in the process of operation.
 /// </summary>
@@ -56,7 +54,7 @@ public InMemoryMarketDataStorage(SecurityId securityId, object arg, Func<DateTim
 
 	/// <inheritdoc />
 	public IAsyncEnumerable<T> LoadAsync(DateTime date, CancellationToken cancellationToken)
-		=> _getData(date).ToAsyncEnumerable2(cancellationToken);
+		=> _getData(date).ToAsyncEnumerable();
 
 	IAsyncEnumerable<Message> IMarketDataStorage.LoadAsync(DateTime date, CancellationToken cancellationToken) => LoadAsync(date, cancellationToken);
 
diff --git a/Algo/Storages/LocalMarketDataDrive.cs b/Algo/Storages/LocalMarketDataDrive.cs
@@ -3,7 +3,6 @@ namespace StockSharp.Algo.Storages;
 using IOPath = System.IO.Path;
 
 using Ecng.Reflection;
-using Ecng.Linq;
 
 using StockSharp.Algo.Storages.Binary;
 
@@ -43,7 +42,7 @@ public LocalMarketDataStorageDrive(DataType dataType, SecurityId secId, StorageF
 			_datesPathObsoleteBin = $"{datesPath}.bin";
 			_datesPathObsoleteTxt = $"{datesPath}.txt";
 
-			_datesDict = new Lazy<CachedSynchronizedOrderedDictionary<DateTime, DateTime>>(() =>
+			_datesDict = new(() =>
 			{
 				var retVal = new CachedSynchronizedOrderedDictionary<DateTime, DateTime>();
 
@@ -83,15 +82,15 @@ public LocalMarketDataStorageDrive(DataType dataType, SecurityId secId, StorageF
 					SaveDates(retVal.CachedValues);
 
 				return retVal;
-			}).Track();
+			});
 		}
 
 		private readonly LocalMarketDataDrive _drive;
 		IMarketDataDrive IMarketDataStorageDrive.Drive => _drive;
 
 		ValueTask<IEnumerable<DateTime>> IMarketDataStorageDrive.GetDatesAsync(CancellationToken cancellationToken) => new(DatesDict.CachedValues);
 
-		private readonly Lazy<CachedSynchronizedOrderedDictionary<DateTime, DateTime>> _datesDict;
+		private readonly ResettableLazy<CachedSynchronizedOrderedDictionary<DateTime, DateTime>> _datesDict;
 		private CachedSynchronizedOrderedDictionary<DateTime, DateTime> DatesDict => _datesDict.Value;
 
 		ValueTask IMarketDataStorageDrive.ClearDatesCacheAsync(CancellationToken cancellationToken)
@@ -771,7 +770,7 @@ private bool TryGetIndex(out Index index)
 	/// </summary>
 	[Obsolete("Use GetAvailableSecuritiesAsync instead.")]
 	public IEnumerable<SecurityId> AvailableSecurities
-		=> AsyncHelper.Run(() => GetAvailableSecuritiesAsync(default).ToArrayAsync2(default));
+		=> AsyncHelper.Run(() => GetAvailableSecuritiesAsync(default).ToArrayAsync(default));
 
 	/// <inheritdoc />
 	public override async IAsyncEnumerable<SecurityId> GetAvailableSecuritiesAsync([EnumeratorCancellation]CancellationToken cancellationToken)
diff --git a/Algo/Storages/MarketDataStorage.cs b/Algo/Storages/MarketDataStorage.cs
@@ -1,7 +1,5 @@
 namespace StockSharp.Algo.Storages;
 
-using Ecng.Linq;
-
 using Nito.AsyncEx;
 
 abstract class MarketDataStorage<TMessage, TId> : IMarketDataStorage<TMessage>
diff --git a/Algo/Storages/MarketDataStorageCache.cs b/Algo/Storages/MarketDataStorageCache.cs
@@ -1,7 +1,5 @@
 ﻿namespace StockSharp.Algo.Storages;
 
-using Ecng.Linq;
-
 /// <summary>
 /// <see cref="IMarketDataStorage"/> cache.
 /// </summary>
@@ -54,7 +52,7 @@ public async IAsyncEnumerable<Message> GetMessagesAsync<TEnumerable>(SecurityId
 
 		if (!_cache.TryGetValue(key, out var t))
 		{
-			var data = await loadIfNeed(date, cancellationToken).ToArrayAsync2(cancellationToken);
+			var data = await loadIfNeed(date, cancellationToken).ToArrayAsync(cancellationToken);
 			t = (now, data.ToArray());
 
 			if (_cache.Count > Limit)
diff --git a/Algo/Storages/SnapshotRegistry.cs b/Algo/Storages/SnapshotRegistry.cs
@@ -267,7 +267,7 @@ public SnapshotStorage(string path, ISnapshotSerializer<TKey, TMessage> serializ
 			_fileNameWithExtension = _serializer.Name.ToLowerInvariant() + ".bin";
 			_datesPath = Path.Combine(_path, _serializer.Name + "Dates.txt");
 
-			_datesDict = new Lazy<CachedSynchronizedOrderedDictionary<DateTime, DateTime>>(() =>
+			_datesDict = new(() =>
 			{
 				var retVal = new CachedSynchronizedOrderedDictionary<DateTime, DateTime>();
 
@@ -290,12 +290,12 @@ public SnapshotStorage(string path, ISnapshotSerializer<TKey, TMessage> serializ
 				}
 
 				return retVal;
-			}).Track();
+			});
 		}
 
 		public override IEnumerable<DateTime> Dates => DatesDict.CachedValues;
 
-		private readonly Lazy<CachedSynchronizedOrderedDictionary<DateTime, DateTime>> _datesDict;
+		private readonly ResettableLazy<CachedSynchronizedOrderedDictionary<DateTime, DateTime>> _datesDict;
 
 		private CachedSynchronizedOrderedDictionary<DateTime, DateTime> DatesDict => _datesDict.Value;
 
diff --git a/Algo/Storages/StorageHelper.cs b/Algo/Storages/StorageHelper.cs
@@ -2,8 +2,6 @@ namespace StockSharp.Algo.Storages;
 
 using System.Diagnostics;
 
-using Ecng.Linq;
-
 using StockSharp.Algo.Candles;
 using StockSharp.Algo.Candles.Compression;
 
@@ -133,7 +131,7 @@ public RangeEnumerable(IMarketDataStorage<TData> storage, DateTime from, DateTim
 	public static IEnumerable<TMessage> Load<TMessage>(this IMarketDataStorage<TMessage> storage, DateTime? from = null, DateTime? to = null)
 		where TMessage : Message, IServerTimeMessage
 	{
-		return AsyncHelper.Run(() => LoadAsync(storage, from, to).ToArrayAsync2(default));
+		return AsyncHelper.Run(() => LoadAsync(storage, from, to).ToArrayAsync(default));
 	}
 
 	/// <summary>
@@ -227,7 +225,7 @@ public static async ValueTask<bool> DeleteAsync(this IMarketDataStorage storage,
 				}
 				else
 				{
-					var data = (await storage.LoadAsync(date, cancellationToken).ToArrayAsync2(cancellationToken)).ToList();
+					var data = (await storage.LoadAsync(date, cancellationToken).ToArrayAsync(cancellationToken)).ToList();
 					data.RemoveWhere(d =>
 					{
 						var t = d.GetServerTime();
@@ -240,7 +238,7 @@ public static async ValueTask<bool> DeleteAsync(this IMarketDataStorage storage,
 				await storage.DeleteAsync(date, cancellationToken);
 			else
 			{
-				var data = (await storage.LoadAsync(date, cancellationToken).ToArrayAsync2(cancellationToken)).ToList();
+				var data = (await storage.LoadAsync(date, cancellationToken).ToArrayAsync(cancellationToken)).ToList();
 				data.RemoveWhere(d => d.GetServerTime() > range.Max);
 				await storage.DeleteAsync(data, cancellationToken);
 			}
@@ -518,7 +516,7 @@ public async IAsyncEnumerable<CandleMessage> LoadAsync(DateTime date, [Enumerato
 
 				if (dates.Contains(date))
 				{
-					var data = await s.LoadAsync(date, cancellationToken).ToArrayAsync2(cancellationToken);
+					var data = await s.LoadAsync(date, cancellationToken).ToArrayAsync(cancellationToken);
 					storagesWithData.Add((s, data));
 				}
 			}
@@ -1609,7 +1607,7 @@ public static IEnumerable<Message> Load(this IMarketDataStorage storage, DateTim
 		if (storage is null)
 			throw new ArgumentNullException(nameof(storage));
 
-		return AsyncHelper.Run(() => storage.LoadAsync(date, default).ToArrayAsync2(default));
+		return AsyncHelper.Run(() => storage.LoadAsync(date, default).ToArrayAsync(default));
 	}
 
 	/// <summary>
@@ -1677,6 +1675,6 @@ public static IEnumerable<TMessage> Load<TMessage>(this IMarketDataStorage<TMess
 		if (storage is null)
 			throw new ArgumentNullException(nameof(storage));
 
-		return AsyncHelper.Run(() => storage.LoadAsync(date, default).ToArrayAsync2(default));
+		return AsyncHelper.Run(() => storage.LoadAsync(date, default).ToArrayAsync(default));
 	}
 }
diff --git a/Algo/Testing/HistoryMessageAdapter.cs b/Algo/Testing/HistoryMessageAdapter.cs
@@ -1,7 +1,5 @@
 namespace StockSharp.Algo.Testing;
 
-using Ecng.Linq;
-
 /// <summary>
 /// The adapter, receiving messages form the storage <see cref="IStorageRegistry"/>.
 /// </summary>
@@ -503,7 +501,7 @@ private void Start(DateTime startDateTime, DateTime stopDateTime, CancellationTo
 							if (AdapterCache is not null)
 							{
 								messages = AdapterCache.GetMessagesAsync(default, default, loadDateInUtc, _basketStorage.LoadAsync, cancellationToken);
-								noData = await messages.FirstOrDefaultAsync2(cancellationToken) is null;
+								noData = await messages.FirstOrDefaultAsync(cancellationToken) is null;
 							}
 							else
 							{
@@ -516,7 +514,7 @@ private void Start(DateTime startDateTime, DateTime stopDateTime, CancellationTo
 							}
 
 							if (noData)
-								await EnqueueMessages(startDateTime, stopDateTime, currentTime, GetSimpleTimeLine(boards, currentTime, MarketTimeChangedInterval).ToAsyncEnumerable2(cancellationToken));
+								await EnqueueMessages(startDateTime, stopDateTime, currentTime, GetSimpleTimeLine(boards, currentTime, MarketTimeChangedInterval).ToAsyncEnumerable());
 							else
 								await EnqueueMessages(startDateTime, stopDateTime, currentTime, messages);
 						}
diff --git a/Algo/TraderHelper.cs b/Algo/TraderHelper.cs
@@ -5,7 +5,6 @@ namespace StockSharp.Algo;
 using Ecng.Compilation;
 using Ecng.Compilation.Expressions;
 using Ecng.IO;
-using Ecng.Linq;
 
 using Nito.AsyncEx;
 
@@ -529,7 +528,7 @@ public static IEnumerable<Security> LookupByCode(this ISecurityProvider provider
 	/// <param name="provider">The provider of information about instruments.</param>
 	/// <returns>All available instruments.</returns>
 	public static IEnumerable<Security> LookupAll(this ISecurityProvider provider)
-		=> AsyncHelper.Run(() => LookupAllAsync(provider, default).ToArrayAsync2(default));
+		=> AsyncHelper.Run(() => LookupAllAsync(provider, default).ToArrayAsync(default));
 
 	/// <summary>
 	/// Get all available instruments.
diff --git a/BusinessEntities/EntitiesExtensions.cs b/BusinessEntities/EntitiesExtensions.cs
@@ -3,7 +3,6 @@ namespace StockSharp.BusinessEntities;
 using System.Reflection;
 
 using Ecng.Configuration;
-using Ecng.Linq;
 using Ecng.Reflection;
 
 /// <summary>
@@ -2355,6 +2354,6 @@ public static IEnumerable<Security> Lookup(this ISecurityProvider provider, Secu
 		if (provider is null)
 			throw new ArgumentNullException(nameof(provider));
 
-		return AsyncHelper.Run(() => provider.LookupAsync(criteria, default).ToArrayAsync2(default));
+		return AsyncHelper.Run(() => provider.LookupAsync(criteria, default).ToArrayAsync(default));
 	}
 }
diff --git a/Diagram.Core/Elements/AlertDiagramElement.cs b/Diagram.Core/Elements/AlertDiagramElement.cs
@@ -1,6 +1,7 @@
 ﻿namespace StockSharp.Diagram.Elements;
 
 using StockSharp.Alerts;
+using StockSharp.Configuration;
 
 /// <summary>
 /// Notification element (sound, window etc.) for specific market events.
diff --git a/Messages/Extensions.cs b/Messages/Extensions.cs
@@ -3,7 +3,6 @@ namespace StockSharp.Messages;
 using System.Collections;
 
 using Ecng.Reflection;
-using Ecng.Linq;
 
 /// <summary>
 /// Extension class.
@@ -5738,6 +5737,6 @@ public static IEnumerable<SecurityMessage> LookupMessages(this ISecurityMessageP
 		if (provider is null)
 			throw new ArgumentNullException(nameof(provider));
 
-		return AsyncHelper.Run(() => provider.LookupMessagesAsync(criteria, default).ToArrayAsync2(default));
+		return AsyncHelper.Run(() => provider.LookupMessagesAsync(criteria, default).ToArrayAsync(default));
 	}
 }
diff --git a/Samples/05_Chart/01_Chart/MainWindow.xaml.cs b/Samples/05_Chart/01_Chart/MainWindow.xaml.cs
@@ -20,7 +20,6 @@
 using Ecng.Compilation.Roslyn;
 using Ecng.Serialization;
 using Ecng.Logging;
-using Ecng.Linq;
 
 using StockSharp.Algo;
 using StockSharp.Algo.Candles.Compression;
@@ -120,7 +119,7 @@ private void Theme_OnClick(object sender, RoutedEventArgs e)
 	private async void HistoryPath_OnFolderChanged(string path)
 	{
 		using var drive = new LocalMarketDataDrive(path);
-		var secs = await drive.GetAvailableSecuritiesAsync(default).ToArrayAsync2(default);
+		var secs = await drive.GetAvailableSecuritiesAsync(default).ToArrayAsync(default);
 
 		Securities.ItemsSource = secs;
 
diff --git a/Samples/06_Strategies/05_HistoryIndex/MainWindow.xaml.cs b/Samples/06_Strategies/05_HistoryIndex/MainWindow.xaml.cs
@@ -55,13 +55,13 @@ private void Start_Click(object sender, RoutedEventArgs e)
 		_security = new Security
 		{
 			Id = Paths.HistoryDefaultSecurity,
-			ExchangeBoard.Binance,
+			Board = ExchangeBoard.Binance,
 		};
 		_indexSecurity = new ExpressionIndexSecurity()
 		{
 			Id = "Index" + Paths.HistoryDefaultSecurity,
 			Expression = $"{_security.Id}/2 + {_security.Id}*100",
-			ExchangeBoard.Binance,
+			Board = ExchangeBoard.Binance,
 		};
 
 		_portfolio = new Portfolio { Name = "test portfolio", BeginValue = 10000000 };
diff --git a/Tests/Helper.cs b/Tests/Helper.cs
@@ -1,6 +1,5 @@
 ﻿namespace StockSharp.Tests;
 
-using Ecng.Linq;
 using Ecng.Reflection;
 
 using StockSharp.Algo.Storages.Csv;
@@ -667,7 +666,7 @@ public static async Task DeleteWithCheckAsync<T>(this IMarketDataStorage<T> stor
 		where T : Message, IServerTimeMessage
 	{
 		await storage.DeleteAsync(cancellationToken: cancellationToken);
-		(await storage.LoadAsync(cancellationToken: cancellationToken).ToArrayAsync2(cancellationToken)).Count().AssertEqual(0);
+		(await storage.LoadAsync(cancellationToken: cancellationToken).ToArrayAsync(cancellationToken)).Count().AssertEqual(0);
 	}
 
 	public static SecurityId CreateSecurityId()
diff --git a/Tests/ImportTests.cs b/Tests/ImportTests.cs
@@ -3,8 +3,6 @@ namespace StockSharp.Tests;
 using StockSharp.Algo.Export;
 using StockSharp.Algo.Import;
 
-using Ecng.Linq;
-
 [TestClass]
 public class ImportTests : BaseTestClass
 {
@@ -85,7 +83,7 @@ private async Task Import<TValue>(DataType dataType, bool addSecId, IEnumerable<
 				ColumnSeparator = ";"
 			};
 
-			var msgs = await parser.Parse(stream, token).ToArrayAsync2(token);
+			var msgs = await parser.Parse(stream, token).ToArrayAsync(token);
 
 			msgs.Length.AssertEqual(importCnt.Value);
 
diff --git a/Tests/StorageTests.cs b/Tests/StorageTests.cs

Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,5 @@`
`1`	`1`	`namespace StockSharp.Algo.Storages.Csv;`
`2`	`2`
`3`		`-using Ecng.Linq;`
`4`		`-`
`5`	`3`	`/// <summary>`
`6`	`4`	`/// The CSV storage of trading objects.`
`7`	`5`	`/// </summary>`
`@@ -137,7 +135,7 @@ IAsyncEnumerable<Security> ISecurityProvider.LookupAsync(SecurityLookupMessage c`
`137`	`135`	`arr = security == null ? [] : [security];`
`138`	`136`	`}`
`139`	`137`
`140`		`- return arr.ToAsyncEnumerable2(cancellationToken);`
	`138`	`+ return arr.ToAsyncEnumerable();`
`141`	`139`	`}`
`142`	`140`
`143`	`141`	`ValueTask<SecurityMessage> ISecurityMessageProvider.LookupMessageByIdAsync(SecurityId id, CancellationToken cancellationToken)`
Original file line number	Diff line number	Diff line change
`@@ -267,7 +267,7 @@ public SnapshotStorage(string path, ISnapshotSerializer<TKey, TMessage> serializ`
`267`	`267`	`_fileNameWithExtension = _serializer.Name.ToLowerInvariant() + ".bin";`
`268`	`268`	`_datesPath = Path.Combine(_path, _serializer.Name + "Dates.txt");`
`269`	`269`
`270`		`- _datesDict = new Lazy<CachedSynchronizedOrderedDictionary<DateTime, DateTime>>(() =>`
	`270`	`+ _datesDict = new(() =>`
`271`	`271`	`{`
`272`	`272`	`var retVal = new CachedSynchronizedOrderedDictionary<DateTime, DateTime>();`
`273`	`273`
`@@ -290,12 +290,12 @@ public SnapshotStorage(string path, ISnapshotSerializer<TKey, TMessage> serializ`
`290`	`290`	`}`
`291`	`291`
`292`	`292`	`return retVal;`
`293`		`- }).Track();`
	`293`	`+ });`
`294`	`294`	`}`
`295`	`295`
`296`	`296`	`public override IEnumerable<DateTime> Dates => DatesDict.CachedValues;`
`297`	`297`
`298`		`- private readonly Lazy<CachedSynchronizedOrderedDictionary<DateTime, DateTime>> _datesDict;`
	`298`	`+ private readonly ResettableLazy<CachedSynchronizedOrderedDictionary<DateTime, DateTime>> _datesDict;`
`299`	`299`
`300`	`300`	`private CachedSynchronizedOrderedDictionary<DateTime, DateTime> DatesDict => _datesDict.Value;`
`301`	`301`
Original file line number	Diff line number	Diff line change
`@@ -2,8 +2,6 @@ namespace StockSharp.Algo.Storages;`
`2`	`2`
`3`	`3`	`using System.Diagnostics;`
`4`	`4`
`5`		`-using Ecng.Linq;`
`6`		`-`
`7`	`5`	`using StockSharp.Algo.Candles;`
`8`	`6`	`using StockSharp.Algo.Candles.Compression;`
`9`	`7`
`@@ -133,7 +131,7 @@ public RangeEnumerable(IMarketDataStorage<TData> storage, DateTime from, DateTim`
`133`	`131`	`public static IEnumerable<TMessage> Load<TMessage>(this IMarketDataStorage<TMessage> storage, DateTime? from = null, DateTime? to = null)`
`134`	`132`	`where TMessage : Message, IServerTimeMessage`
`135`	`133`	`{`
`136`		`- return AsyncHelper.Run(() => LoadAsync(storage, from, to).ToArrayAsync2(default));`
	`134`	`+ return AsyncHelper.Run(() => LoadAsync(storage, from, to).ToArrayAsync(default));`
`137`	`135`	`}`
`138`	`136`
`139`	`137`	`/// <summary>`
`@@ -227,7 +225,7 @@ public static async ValueTask<bool> DeleteAsync(this IMarketDataStorage storage,`
`227`	`225`	`}`
`228`	`226`	`else`
`229`	`227`	`{`
`230`		`- var data = (await storage.LoadAsync(date, cancellationToken).ToArrayAsync2(cancellationToken)).ToList();`
	`228`	`+ var data = (await storage.LoadAsync(date, cancellationToken).ToArrayAsync(cancellationToken)).ToList();`
`231`	`229`	`data.RemoveWhere(d =>`
`232`	`230`	`{`
`233`	`231`	`var t = d.GetServerTime();`
`@@ -240,7 +238,7 @@ public static async ValueTask<bool> DeleteAsync(this IMarketDataStorage storage,`
`240`	`238`	`await storage.DeleteAsync(date, cancellationToken);`
`241`	`239`	`else`
`242`	`240`	`{`
`243`		`- var data = (await storage.LoadAsync(date, cancellationToken).ToArrayAsync2(cancellationToken)).ToList();`
	`241`	`+ var data = (await storage.LoadAsync(date, cancellationToken).ToArrayAsync(cancellationToken)).ToList();`
`244`	`242`	`data.RemoveWhere(d => d.GetServerTime() > range.Max);`
`245`	`243`	`await storage.DeleteAsync(data, cancellationToken);`
`246`	`244`	`}`
`@@ -518,7 +516,7 @@ public async IAsyncEnumerable<CandleMessage> LoadAsync(DateTime date, [Enumerato`
`518`	`516`
`519`	`517`	`if (dates.Contains(date))`
`520`	`518`	`{`
`521`		`- var data = await s.LoadAsync(date, cancellationToken).ToArrayAsync2(cancellationToken);`
	`519`	`+ var data = await s.LoadAsync(date, cancellationToken).ToArrayAsync(cancellationToken);`
`522`	`520`	`storagesWithData.Add((s, data));`
`523`	`521`	`}`
`524`	`522`	`}`
`@@ -1609,7 +1607,7 @@ public static IEnumerable<Message> Load(this IMarketDataStorage storage, DateTim`
`1609`	`1607`	`if (storage is null)`
`1610`	`1608`	`throw new ArgumentNullException(nameof(storage));`
`1611`	`1609`
`1612`		`- return AsyncHelper.Run(() => storage.LoadAsync(date, default).ToArrayAsync2(default));`
	`1610`	`+ return AsyncHelper.Run(() => storage.LoadAsync(date, default).ToArrayAsync(default));`
`1613`	`1611`	`}`
`1614`	`1612`
`1615`	`1613`	`/// <summary>`
`@@ -1677,6 +1675,6 @@ public static IEnumerable<TMessage> Load<TMessage>(this IMarketDataStorage<TMess`
`1677`	`1675`	`if (storage is null)`
`1678`	`1676`	`throw new ArgumentNullException(nameof(storage));`
`1679`	`1677`
`1680`		`- return AsyncHelper.Run(() => storage.LoadAsync(date, default).ToArrayAsync2(default));`
	`1678`	`+ return AsyncHelper.Run(() => storage.LoadAsync(date, default).ToArrayAsync(default));`
`1681`	`1679`	`}`
`1682`	`1680`	`}`