AsyncCircuitBreakerPolicy<TResult>
public class AsyncCircuitBreakerPolicy<TResult> : AsyncPolicy<TResult>, ICircuitBreakerPolicy<TResult>, ICircuitBreakerPolicy, IsPolicy
using System;
using System.Diagnostics;
using System.Threading;
using System.Threading.Tasks;
namespace Polly.CircuitBreaker
{
public class AsyncCircuitBreakerPolicy<TResult> : AsyncPolicy<TResult>, ICircuitBreakerPolicy<TResult>, ICircuitBreakerPolicy, IsPolicy
{
internal readonly ICircuitController<TResult> _breakerController;
public CircuitState CircuitState => _breakerController.CircuitState;
public Exception LastException => _breakerController.LastException;
public TResult LastHandledResult => _breakerController.LastHandledResult;
internal AsyncCircuitBreakerPolicy(PolicyBuilder<TResult> policyBuilder, ICircuitController<TResult> breakerController)
: base(policyBuilder)
{
_breakerController = breakerController;
}
public void Isolate()
{
_breakerController.Isolate();
}
public void Reset()
{
_breakerController.Reset();
}
[DebuggerStepThrough]
protected override Task<TResult> ImplementationAsync(Func<Context, CancellationToken, Task<TResult>> action, Context context, CancellationToken cancellationToken, bool continueOnCapturedContext)
{
return AsyncCircuitBreakerEngine.ImplementationAsync<TResult>(action, context, cancellationToken, continueOnCapturedContext, base.ExceptionPredicates, base.ResultPredicates, _breakerController);
}
}
}