public async Task Heartbeat()

in rocketmq-client-csharp/Client.cs [271:293]

• 19 lines of code
• 3 McCabe index (conditional complexity)

        public async Task Heartbeat()
        {
            List<string> endpoints = AvailableBrokerEndpoints();
            if (0 == endpoints.Count)
            {
                Logger.Debug("No broker endpoints available in topic route");
                return;
            }

            var request = new rmq::HeartbeatRequest();
            PrepareHeartbeatData(request);

            var metadata = new grpc::Metadata();
            Signature.sign(this, metadata);

            List<Task> tasks = new List<Task>();
            foreach (var endpoint in endpoints)
            {
                tasks.Add(Manager.Heartbeat(endpoint, metadata, request, RequestTimeout));
            }

            await Task.WhenAll(tasks);
        }