MediatorPipelineModule.cs

public class MediatorPipelineModule : Autofac.Module
    {
        protected override void Load(ContainerBuilder builder)
        {
            RegisterPipeline(builder);
            RegisterAsyncPreRequestHandlers(builder);
            RegisterAsyncPostRequestHandlers(builder);
            RegisterPreRequestHandlers(builder);
            RegisterPostRequestHandlers(builder);
        }

        private static void RegisterPipeline(ContainerBuilder builder)
        {
            builder.RegisterGenericDecorator(typeof (AsyncMediatorPipeline<,>), typeof (IAsyncRequestHandler<,>),
                "async-handler")
                .InstancePerLifetimeScope();

            builder.RegisterGenericDecorator(typeof (MediatorPipeline<,>), typeof (IRequestHandler<,>), "handler")
                .InstancePerLifetimeScope();
        }

        private static void RegisterPostRequestHandlers(ContainerBuilder builder)
        {
            builder.RegisterAssemblyTypes(Assembly.GetExecutingAssembly())
                .As(type => type.GetInterfaces()
                    .Where(interfacetype => interfacetype.IsClosedTypeOf(typeof(IPostRequestHandler<,>))))
                .InstancePerLifetimeScope();
        }

        private static void RegisterAsyncPostRequestHandlers(ContainerBuilder builder)
        {
            builder.RegisterAssemblyTypes(Assembly.GetExecutingAssembly())
                .As(type => type.GetInterfaces()
                    .Where(interfacetype => interfacetype.IsClosedTypeOf(typeof(IAsyncPostRequestHandler<,>))))
                .InstancePerLifetimeScope();
        }

        private static void RegisterPreRequestHandlers(ContainerBuilder builder)
        {
            builder.RegisterAssemblyTypes(Assembly.GetExecutingAssembly())
                .As(type => type.GetInterfaces()
                    .Where(interfacetype => interfacetype.IsClosedTypeOf(typeof(IPreRequestHandler<>))))
                .InstancePerLifetimeScope();
        }

        private static void RegisterAsyncPreRequestHandlers(ContainerBuilder builder)
        {
            builder.RegisterAssemblyTypes(Assembly.GetExecutingAssembly())
                .As(type => type.GetInterfaces()
                    .Where(interfacetype => interfacetype.IsClosedTypeOf(typeof(IAsyncPreRequestHandler<>))))
                .InstancePerLifetimeScope();
        }
    }