Fix test

test/ToMqttNet.Test.Unit/MqttConnectionServiceTests.cs

@@ -55,8 +55,9 @@
 		var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(10));
 
 		// Act
+		_clientStub.IsConnected = true;
 		await _sut.StartAsync(cancellationTokenSource.Token);
-		await _clientStub.CallConnectedAsync(new MqttClientConnectedEventArgs(new MqttClientConnectResult()));
+		await _clientStub.CallConnectionStateChangedAsync(new MqttClientConnectedEventArgs(new MqttClientConnectResult()));
 
 		// Assert
 		listener.RecordObservableInstruments();
@@ -87,7 +88,7 @@
 		var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(10));
 
 		await _sut.StartAsync(cancellationTokenSource.Token);
-		await _clientStub.CallConnectedAsync(new MqttClientConnectedEventArgs(new MqttClientConnectResult()));
+		await _clientStub.CallConnectionStateChangedAsync(new MqttClientConnectedEventArgs(new MqttClientConnectResult()));
 
 		var message = new MqttApplicationMessageBuilder()
 			.WithTopic("my-topic")
@@ -106,7 +107,7 @@
 {
 	public IMqttClient InternalClient => throw new NotImplementedException();
 
-	public bool IsConnected => throw new NotImplementedException();
+	public bool IsConnected { get; set; }
 
 	public bool IsStarted => throw new NotImplementedException();
 
@@ -114,9 +115,9 @@
 
 	public int PendingApplicationMessagesCount => throw new NotImplementedException();
 
 	public event Func<ApplicationMessageProcessedEventArgs, Task> ApplicationMessageProcessedAsync = null!;
 	public event Func<MqttApplicationMessageReceivedEventArgs, Task> ApplicationMessageReceivedAsync = null!;
 	public event Func<ApplicationMessageSkippedEventArgs, Task> ApplicationMessageSkippedAsync = null!;
 	public event Func<MqttClientConnectedEventArgs, Task> ConnectedAsync = null!;
 
 	public Task CallConnectedAsync(MqttClientConnectedEventArgs args)
@@ -124,14 +125,18 @@
 		return ConnectedAsync.Invoke(args);
 	}
 
 	public event Func<ConnectingFailedEventArgs, Task> ConnectingFailedAsync = null!;
 	public event Func<EventArgs, Task> ConnectionStateChangedAsync = null!;
+	public Task CallConnectionStateChangedAsync(EventArgs args)
+	{
+		return ConnectionStateChangedAsync.Invoke(args);
+	}
 	public event Func<MqttClientDisconnectedEventArgs, Task> DisconnectedAsync = null!;
 	public Task CallDisconnectedAsync(MqttClientDisconnectedEventArgs args)
 	{
 		return DisconnectedAsync.Invoke(args);
 	}
 	public event Func<ManagedProcessFailedEventArgs, Task> SynchronizingSubscriptionsFailedAsync = null!;
 
 	public List<MqttApplicationMessage> EnqueuedMessage = new List<MqttApplicationMessage>();
 	public List<MqttTopicFilter> Subscriptions = new List<MqttTopicFilter>();