ResiliencePipelineAsyncPolicy<TResult>
using System;
using System.Runtime.CompilerServices;
using System.Threading;
using System.Threading.Tasks;
namespace Polly.Utilities.Wrappers
{
internal sealed class ResiliencePipelineAsyncPolicy<TResult> : AsyncPolicy<TResult>
{
private readonly ResiliencePipeline<TResult> _pipeline;
public ResiliencePipelineAsyncPolicy(ResiliencePipeline<TResult> strategy)
: base((PolicyBuilder<TResult>)null)
{
_pipeline = strategy;
}
[AsyncStateMachine(typeof(ResiliencePipelineAsyncPolicy<>.<ImplementationAsync>d__2))]
protected override Task<TResult> ImplementationAsync(Func<Context, CancellationToken, Task<TResult>> action, Context context, CancellationToken cancellationToken, bool continueOnCapturedContext)
{
<ImplementationAsync>d__2 stateMachine = default(<ImplementationAsync>d__2);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<TResult>.Create();
stateMachine.<>4__this = this;
stateMachine.action = action;
stateMachine.context = context;
stateMachine.cancellationToken = cancellationToken;
stateMachine.continueOnCapturedContext = continueOnCapturedContext;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
}
}