src/Persistence/MassTransit.EntityFrameworkIntegration/EntityFrameworkIntegration/Saga/CustomSagaLoadQueryProvider.cs - develop - vshmidt/masstransit

src/Persistence/MassTransit.EntityFrameworkIntegration/EntityFrameworkIntegration/Saga/CustomSagaLoadQueryProvider.cs

26 строк760 B

Chris Patterson

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

22 янв 2022, 18:24

22 янв 2022, 18:24b5b4f50

namespace MassTransit.EntityFrameworkIntegration.Saga
{
    using System;
    using System.Data.Entity;
    using System.Linq;


    public class CustomSagaLoadQueryProvider<TSaga> :
        ILoadQueryProvider<TSaga>
        where TSaga : class, ISaga
    {
        readonly Func<IQueryable<TSaga>, IQueryable<TSaga>> _customize;
        readonly ILoadQueryProvider<TSaga> _source;

        public CustomSagaLoadQueryProvider(ILoadQueryProvider<TSaga> source, Func<IQueryable<TSaga>, IQueryable<TSaga>> customize)
        {
            _source = source;
            _customize = customize;
        }

        public IQueryable<TSaga> GetQueryable(DbContext dbContext)
        {
            return _customize(_source.GetQueryable(dbContext));
        }
    }
}