using System; using System.Threading; namespace Polly.Wrap { internal static class PolicyWrapEngine { internal static TResult Implementation<TResult>(Func<Context, CancellationToken, TResult> func, Context context, ISyncPolicy<TResult> outerPolicy, ISyncPolicy<TResult> innerPolicy, CancellationToken cancellationToken) { return outerPolicy.Execute((Func<Context, CancellationToken, TResult>)((Context ctx, CancellationToken ct) => innerPolicy.Execute(func, ctx, ct)), context, cancellationToken); } internal static TResult Implementation<TResult>(Func<Context, CancellationToken, TResult> func, Context context, ISyncPolicy<TResult> outerPolicy, ISyncPolicy innerPolicy, CancellationToken cancellationToken) { return outerPolicy.Execute((Func<Context, CancellationToken, TResult>)((Context ctx, CancellationToken ct) => innerPolicy.Execute<TResult>(func, ctx, ct)), context, cancellationToken); } internal static TResult Implementation<TResult>(Func<Context, CancellationToken, TResult> func, Context context, ISyncPolicy outerPolicy, ISyncPolicy<TResult> innerPolicy, CancellationToken cancellationToken) { return outerPolicy.Execute((Context ctx, CancellationToken ct) => innerPolicy.Execute(func, ctx, ct), context, cancellationToken); } internal static TResult Implementation<TResult>(Func<Context, CancellationToken, TResult> func, Context context, ISyncPolicy outerPolicy, ISyncPolicy innerPolicy, CancellationToken cancellationToken) { return outerPolicy.Execute((Context ctx, CancellationToken ct) => innerPolicy.Execute<TResult>(func, ctx, ct), context, cancellationToken); } internal static void Implementation(Action<Context, CancellationToken> action, Context context, ISyncPolicy outerPolicy, ISyncPolicy innerPolicy, CancellationToken cancellationToken) { outerPolicy.Execute(delegate(Context ctx, CancellationToken ct) { innerPolicy.Execute(action, ctx, ct); }, context, cancellationToken); } } }