File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
src/Extensions/NetDaemon.Extensions.MqttEntityManager Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change 99
1010namespace NetDaemon . Extensions . MqttEntityManager ;
1111
12- ''' /// <summary>
12+ /// <summary>
1313/// Wrapper to assure an MQTT connection
1414/// </summary>
1515internal class AssuredMqttConnection : IAssuredMqttConnection , IDisposable
@@ -66,7 +66,7 @@ private async Task ConnectAsync(CancellationToken cancellationToken)
6666
6767 _mqttClient . ConnectedAsync += MqttClientOnConnectedAsync ;
6868 _mqttClient . DisconnectedAsync += MqttClientOnDisconnectedAsync ;
69-
69+
7070 while ( ! cancellationToken . IsCancellationRequested )
7171 {
7272 try
@@ -86,7 +86,7 @@ private Task MqttClientOnDisconnectedAsync(MqttClientDisconnectedEventArgs arg)
8686 {
8787 _logger . LogDebug ( "MQTT disconnected: {Reason}" , BuildErrorResponse ( arg ) ) ;
8888 if ( _disposed ) return Task . CompletedTask ;
89-
89+
9090 _ = Task . Run ( async ( ) =>
9191 {
9292 await Task . Delay ( 5000 ) . ConfigureAwait ( false ) ;
@@ -135,4 +135,4 @@ public void Dispose()
135135 _mqttClient . Dispose ( ) ;
136136 }
137137 }
138- } ''
138+ }
You can’t perform that action at this time.
0 commit comments