AsyncCircuitBreakerPolicy
using Polly.Utilities;
using System;
using System.Runtime.CompilerServices;
using System.Threading;
using System.Threading.Tasks;
namespace Polly.CircuitBreaker
{
public class AsyncCircuitBreakerPolicy : AsyncPolicy, ICircuitBreakerPolicy, IsPolicy
{
internal readonly ICircuitController<EmptyStruct> _breakerController;
public CircuitState CircuitState => _breakerController.CircuitState;
public Exception LastException => _breakerController.LastException;
internal AsyncCircuitBreakerPolicy(PolicyBuilder policyBuilder, ICircuitController<EmptyStruct> breakerController)
: base(policyBuilder)
{
_breakerController = breakerController;
}
public void Isolate()
{
_breakerController.Isolate();
}
public void Reset()
{
_breakerController.Reset();
}
[AsyncStateMachine(typeof(<ImplementationAsync>d__8<>))]
protected override Task<TResult> ImplementationAsync<TResult>(Func<Context, CancellationToken, Task<TResult>> action, Context context, CancellationToken cancellationToken, bool continueOnCapturedContext)
{
<ImplementationAsync>d__8<TResult> stateMachine = default(<ImplementationAsync>d__8<TResult>);
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;
}
}
}