FallbackEngine
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
namespace Polly.Fallback
{
internal static class FallbackEngine
{
internal static TResult Implementation<TResult>(Func<CancellationToken, TResult> action, Context context, CancellationToken cancellationToken, IEnumerable<ExceptionPredicate> shouldHandleExceptionPredicates, IEnumerable<ResultPredicate<TResult>> shouldHandleResultPredicates, Action<DelegateResult<TResult>, Context> onFallback, Func<CancellationToken, TResult> fallbackAction)
{
cancellationToken.ThrowIfCancellationRequested();
DelegateResult<TResult> delegateOutcome;
try {
delegateOutcome = (DelegateResult<TResult>)new DelegateResult<TResult>(action(cancellationToken));
cancellationToken.ThrowIfCancellationRequested();
if (!shouldHandleResultPredicates.Any((ResultPredicate<TResult> predicate) => predicate(((DelegateResult<TResult>)delegateOutcome).Result)))
return ((DelegateResult<TResult>)delegateOutcome).Result;
} catch (Exception ex2) {
Exception ex;
Exception ex3 = ex = ex2;
if (cancellationToken.IsCancellationRequested) {
if (ex is OperationCanceledException && ((OperationCanceledException)ex).CancellationToken == cancellationToken)
throw;
cancellationToken.ThrowIfCancellationRequested();
}
if (!shouldHandleExceptionPredicates.Any((ExceptionPredicate predicate) => predicate(ex)))
throw;
delegateOutcome = (DelegateResult<TResult>)new DelegateResult<TResult>(ex);
}
onFallback((DelegateResult<TResult>)delegateOutcome, context);
cancellationToken.ThrowIfCancellationRequested();
return fallbackAction(cancellationToken);
}
internal static async Task<TResult> ImplementationAsync<TResult>(Func<CancellationToken, Task<TResult>> action, Context context, IEnumerable<ExceptionPredicate> shouldHandleExceptionPredicates, IEnumerable<ResultPredicate<TResult>> shouldHandleResultPredicates, Func<DelegateResult<TResult>, Context, Task> onFallbackAsync, Func<CancellationToken, Task<TResult>> fallbackAction, CancellationToken cancellationToken, bool continueOnCapturedContext)
{
cancellationToken.ThrowIfCancellationRequested();
DelegateResult<TResult> delegateOutcome;
try {
<>c__DisplayClass1_0<TResult> <>c__DisplayClass1_;
DelegateResult<TResult> delegateOutcome2 = <>c__DisplayClass1_.delegateOutcome;
delegateOutcome = (DelegateResult<TResult>)new DelegateResult<TResult>(await action(cancellationToken).ConfigureAwait(continueOnCapturedContext));
cancellationToken.ThrowIfCancellationRequested();
if (!Enumerable.Any<ResultPredicate<TResult>>(shouldHandleResultPredicates, (Func<ResultPredicate<TResult>, bool>)((ResultPredicate<TResult> predicate) => predicate(((DelegateResult<TResult>)delegateOutcome).Result))))
return ((DelegateResult<TResult>)delegateOutcome).Result;
} catch (Exception ex2) {
Exception ex = ex2;
if (cancellationToken.IsCancellationRequested) {
if (ex is OperationCanceledException && ((OperationCanceledException)ex).CancellationToken == cancellationToken)
throw;
cancellationToken.ThrowIfCancellationRequested();
}
if (!Enumerable.Any<ExceptionPredicate>(shouldHandleExceptionPredicates, (Func<ExceptionPredicate, bool>)((ExceptionPredicate predicate) => predicate(ex))))
throw;
delegateOutcome = (DelegateResult<TResult>)new DelegateResult<TResult>(ex);
}
await onFallbackAsync((DelegateResult<TResult>)delegateOutcome, context).ConfigureAwait(continueOnCapturedContext);
cancellationToken.ThrowIfCancellationRequested();
return await fallbackAction(cancellationToken).ConfigureAwait(continueOnCapturedContext);
}
}
}