Removed obsolete.

Author: mikasoukhov

Algo/Basket/IPendingMessageManager.cs

@@ -3,7 +3,7 @@ namespace StockSharp.Tests;
 using StockSharp.Algo.Basket;
 
 /// <summary>
-/// Tests for <see cref="PendingMessageManager"/> and <see cref="PendingMessageState"/>.
+/// Tests for <see cref="PendingMessageState"/>.
 /// </summary>
 [TestClass]
 public class PendingMessageManagerTests
@@ -64,121 +64,4 @@ public void State_Count_ReturnsCorrectCount()
 	}
 
 	#endregion
-
-	#region PendingMessageManager Tests
-
-	[TestMethod]
-	public void Manager_HasPendingAdapters_EnqueuesMessage()
-	{
-		// Arrange
-		var state = new PendingMessageState();
-		var manager = new PendingMessageManager(state);
-		var message = new SecurityMessage();
-
-		// Act - hasPendingAdapters=true means adapters are still connecting
-		var enqueued = manager.TryEnqueue(message, ConnectionStates.Connecting, hasPendingAdapters: true, totalAdapters: 1);
-
-		// Assert
-		enqueued.AssertTrue();
-		manager.HasPending.AssertTrue();
-		state.Count.AssertEqual(1);
-	}
-
-	[TestMethod]
-	public void Manager_AllConnected_DoesNotEnqueue()
-	{
-		// Arrange
-		var state = new PendingMessageState();
-		var manager = new PendingMessageManager(state);
-		var message = new SecurityMessage();
-
-		// Act - no pending adapters, 1 total adapter = all connected
-		var enqueued = manager.TryEnqueue(message, ConnectionStates.Connected, hasPendingAdapters: false, totalAdapters: 1);
-
-		// Assert
-		enqueued.AssertFalse();
-		manager.HasPending.AssertFalse();
-	}
-
-	[TestMethod]
-	public void Manager_NoAdapters_EnqueuesMessage()
-	{
-		// Arrange
-		var state = new PendingMessageState();
-		var manager = new PendingMessageManager(state);
-		var message = new SecurityMessage();
-
-		// Act - totalAdapters=0 means no adapters at all, should enqueue
-		var enqueued = manager.TryEnqueue(message, ConnectionStates.Disconnected, hasPendingAdapters: false, totalAdapters: 0);
-
-		// Assert
-		enqueued.AssertTrue();
-	}
-
-	[TestMethod]
-	public void Manager_DequeueAll_ReturnsAllAndClears()
-	{
-		// Arrange
-		var state = new PendingMessageState();
-		var manager = new PendingMessageManager(state);
-		var msg1 = new SecurityMessage();
-		var msg2 = new PortfolioMessage();
-
-		manager.TryEnqueue(msg1, ConnectionStates.Connecting, hasPendingAdapters: true, totalAdapters: 1);
-		manager.TryEnqueue(msg2, ConnectionStates.Connecting, hasPendingAdapters: true, totalAdapters: 1);
-
-		// Act
-		var messages = manager.DequeueAll();
-
-		// Assert
-		messages.Length.AssertEqual(2);
-		manager.HasPending.AssertFalse();
-	}
-
-	[TestMethod]
-	public void Manager_FullCycle_BuffersUntilConnected()
-	{
-		// Arrange
-		var state = new PendingMessageState();
-		var manager = new PendingMessageManager(state);
-
-		// Enqueue while pending adapters exist
-		var msg1 = new SecurityMessage { SecurityId = new SecurityId { SecurityCode = "AAPL" } };
-		var msg2 = new MarketDataMessage { SecurityId = new SecurityId { SecurityCode = "GOOG" }, DataType2 = DataType.Ticks };
-
-		manager.TryEnqueue(msg1, ConnectionStates.Disconnected, hasPendingAdapters: true, totalAdapters: 1).AssertTrue();
-		manager.TryEnqueue(msg2, ConnectionStates.Connecting, hasPendingAdapters: true, totalAdapters: 1).AssertTrue();
-
-		manager.HasPending.AssertTrue();
-
-		// Simulate connected - messages should be dequeued
-		var pending = manager.DequeueAll();
-
-		// Assert
-		pending.Length.AssertEqual(2);
-		manager.HasPending.AssertFalse();
-	}
-
-	#endregion
-
-	#region Mock State Tests
-
-	[TestMethod]
-	public void Manager_WithMockState_VerifiesAddCall()
-	{
-		// Arrange
-		var mockState = new Mock<IPendingMessageState>();
-		mockState.Setup(s => s.Count).Returns(0);
-
-		var manager = new PendingMessageManager(mockState.Object);
-		var message = new SecurityMessage();
-
-		// Act
-		manager.TryEnqueue(message, ConnectionStates.Connecting, hasPendingAdapters: true, totalAdapters: 1);
-
-		// Assert
-		mockState.Verify(s => s.Add(It.IsAny<Message>()), Times.Once);
-	}
-
-	#endregion
 }

Algo/Basket/PendingMessageManager.cs

@@ -2,20 +2,14 @@ namespace StockSharp.Tests;
 
 internal abstract class TestLogReceiver : BaseLogReceiver
 {
-	private DateTime _timeUtc = new(2024, 1, 1, 0, 0, 0, DateTimeKind.Utc);
-
 	protected TestLogReceiver()
 	{
 		Log += message => Logs.Add(message);
 	}
 
 	public List<LogMessage> Logs { get; } = [];
 
-	public DateTime TimeUtc
-	{
-		get => _timeUtc;
-		set => _timeUtc = value;
-	}
+	public DateTime Time { get; set; } = new(2024, 1, 1, 0, 0, 0, DateTimeKind.Utc);
 
-	public override DateTime CurrentTime => _timeUtc;
+	public override DateTime CurrentTime => Time;
 }