in rocketmq-client-csharp/ClientManager.cs [302:319]
public async Task Shutdown()
{
_clientLock.EnterReadLock();
try
{
List<Task> tasks = new List<Task>();
foreach (var item in _rpcClients)
{
tasks.Add(item.Value.Shutdown());
}
await Task.WhenAll(tasks);
}
finally
{
_clientLock.ExitReadLock();
}
}