in rocketmq-client-csharp/Client.cs [419:444]
public async Task<bool> NotifyClientTermination()
{
List<string> endpoints = AvailableBrokerEndpoints();
var request = new rmq::NotifyClientTerminationRequest();
var metadata = new grpc.Metadata();
Signature.sign(this, metadata);
List<Task<Boolean>> tasks = new List<Task<Boolean>>();
foreach (var endpoint in endpoints)
{
tasks.Add(Manager.NotifyClientTermination(endpoint, metadata, request, RequestTimeout));
}
bool[] results = await Task.WhenAll(tasks);
foreach (bool b in results)
{
if (!b)
{
return false;
}
}
return true;
}