public async Task FlushAsync()

in src/Microsoft.Azure.WebJobs.Extensions.Dapr/Bindings/DaprInvokeMethodAsyncCollector.cs [49:61]

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

        public async Task FlushAsync(CancellationToken cancellationToken = default)
        {
            while (this.requests.TryDequeue(out InvokeMethodParameters item))
            {
                await this.daprService.InvokeMethodAsync(
                    this.attr.DaprAddress,
                    item.AppId!,
                    item.MethodName!,
                    item.HttpVerb!,
                    item.Body,
                    cancellationToken);
            }
        }