Skip to content

Commit

Permalink
Fix build
Browse files Browse the repository at this point in the history
  • Loading branch information
chkr1011 committed May 12, 2024
1 parent c5578a9 commit ae4f168
Showing 1 changed file with 8 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -598,12 +598,13 @@ public async Task Subscribe_Does_Not_Hang_On_Server_Stop()
}
receivedOnServer.Release();
}
return Task.CompletedTask;
return CompletedTask.Instance;
};
managedClient.SynchronizingSubscriptionsFailedAsync += e =>
{
failedOnClient.Release();
return Task.CompletedTask;
return CompletedTask.Instance;
};

await managedClient.SubscribeAsync(topic);
Expand Down Expand Up @@ -643,12 +644,13 @@ public async Task Unsubscribe_Does_Not_Hang_On_Server_Stop()
{
receivedOnServer.Release();
}
return Task.CompletedTask;
return CompletedTask.Instance;
};
managedClient.SynchronizingSubscriptionsFailedAsync += e =>
{
failedOnClient.Release();
return Task.CompletedTask;
return CompletedTask.Instance;
};

await managedClient.SubscribeAsync(topic);
Expand Down Expand Up @@ -692,9 +694,9 @@ public async Task Publish_Does_Not_Hang_On_Server_Error()
receivedOnServer.TrySetResult(null);
}
}
return Task.CompletedTask;
};
return CompletedTask.Instance;
};

await managedClient.EnqueueAsync(new MqttApplicationMessage { Topic = topic, PayloadSegment = new ArraySegment<byte>(new byte[] { 1 }), Retain = true, QualityOfServiceLevel = MqttQualityOfServiceLevel.AtLeastOnce });

Expand Down

0 comments on commit ae4f168

Please sign in to comment.