public async Task FlushAsync()

in src/Microsoft.Azure.WebJobs.Extensions.Dapr/Bindings/DaprBindingAsyncCollector.cs [37:46]

• 10 lines of code
• 2 McCabe index (conditional complexity)

        public async Task FlushAsync(CancellationToken cancellationToken = default)
        {
            while (this.requests.TryDequeue(out DaprBindingMessage item))
            {
                await this.daprServiceClient.SendToDaprBindingAsync(
                    this.attr.DaprAddress,
                    item!,
                    cancellationToken);
            }
        }