public async Task FlushAsync()

in src/MySqlAsyncCollector.cs [131:152]

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

        public async Task FlushAsync(CancellationToken cancellationToken = default)
        {
            await this._rowLock.WaitAsync(cancellationToken);
            try
            {
                if (this._rows.Count != 0)
                {
                    this._logger.LogInformation($"Sending event Flush Async");
                    await this.UpsertRowsAsync(this._rows, this._attribute, this._configuration);
                    this._rows.Clear();
                }
            }
            catch (Exception ex)
            {
                this._logger.LogError($"Error sending event Flush Async. Message={ex.Message}");
                throw;
            }
            finally
            {
                this._rowLock.Release();
            }
        }