public void ReadMessages()

in backend/MXApi/Services/MessagingService.cs [30:52]

• 21 lines of code
• 4 McCabe index (conditional complexity)

    public void ReadMessages(CancellationToken ct)
    {
      var d2CPartitions = _eventHubClient.GetRuntimeInformation().PartitionIds;

      var tasks = new List<Task>();
      foreach (string partition in d2CPartitions)
      {
        tasks.Add(ReceiveMessagesFromDeviceAsync(partition, ct));
      }
      
      try
      {
        Task.WaitAll(tasks.ToArray());
      }
      catch (AggregateException e)
      {
        if (!(e.InnerException is OperationCanceledException))
        {
          Trace.TraceError($"An error occurred while processing messages: {e}");
          throw;
        }
      }
    }