AsyncBulkheadEngine
using System;
using System.Runtime.CompilerServices;
using System.Threading;
using System.Threading.Tasks;
using System;
using System.Runtime.CompilerServices;
using System.Threading;
using System.Threading.Tasks;
namespace Polly.Fallback
{
internal class AsyncFallbackEngine
{
[AsyncStateMachine(typeof(<ImplementationAsync>d__0<>))]
internal static Task<TResult> ImplementationAsync<TResult>(Func<Context, CancellationToken, Task<TResult>> action, Context context, CancellationToken cancellationToken, ExceptionPredicates shouldHandleExceptionPredicates, ResultPredicates<TResult> shouldHandleResultPredicates, Func<DelegateResult<TResult>, Context, Task> onFallbackAsync, Func<DelegateResult<TResult>, Context, CancellationToken, Task<TResult>> fallbackAction, bool continueOnCapturedContext)
{
<ImplementationAsync>d__0<TResult> stateMachine = default(<ImplementationAsync>d__0<TResult>);
<ImplementationAsync>d__0<TResult> stateMachine = default(<ImplementationAsync>d__0<TResult>);
stateMachine.action = action;
stateMachine.context = context;
stateMachine.cancellationToken = cancellationToken;
stateMachine.shouldHandleExceptionPredicates = shouldHandleExceptionPredicates;
stateMachine.shouldHandleResultPredicates = shouldHandleResultPredicates;
stateMachine.onFallbackAsync = onFallbackAsync;
stateMachine.fallbackAction = fallbackAction;
stateMachine.continueOnCapturedContext = continueOnCapturedContext;
stateMachine.<>t__builder = AsyncTaskMethodBuilder<TResult>.Create();
stateMachine.<>1__state = -1;
AsyncTaskMethodBuilder<TResult> <>t__builder = stateMachine.<>t__builder;
AsyncTaskMethodBuilder<TResult> <>t__builder;
<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
}
}