public override AsyncUnaryCall AsyncUnaryCall()

in src/Middleware/Grpc/Client/Retry.cs [23:61]
34 lines of code
3 McCabe index (conditional complexity)

    public override AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(
    TRequest request,
    ClientInterceptorContext<TRequest, TResponse> context,
    AsyncUnaryCallContinuation<TRequest, TResponse> continuation)
    {
        return _retryPolicy.ExecuteAsync(async () =>
        {
            try
            {
                // Call the continuation function to proceed with the call
                var call = continuation(request, context);

                // Await the result of the call
                var response = await call.ResponseAsync;
                var responseHeaders = await call.ResponseHeadersAsync;
                var status = call.GetStatus();
                var trailers = call.GetTrailers();
                var dispose = call.Dispose;

                // Return a new AsyncUnaryCall with the awaited results
                return new AsyncUnaryCall<TResponse>(
                    Task.FromResult(response),
                    Task.FromResult(responseHeaders),
                    () => status,
                    () => trailers,
                    dispose);
            }
            catch (RpcException ex)
            {
                Console.WriteLine($"RpcException occurred: {ex.Status}");
                throw;
            }
            catch (Exception ex)
            {
                Console.WriteLine($"Exception occurred: {ex.Message}");
                throw;
            }
        }).Result; // Use .Result to unwrap the Task and return the AsyncUnaryCall object
    }