Pipeline.cs

Go to the documentation of this file.

using System.Linq.Expressions;
using Fauna.Serialization;
 
namespace Fauna.Linq;
 
public enum PipelineMode
{
    Query,
    Project,
    SetLoad,
    Scalar,
}
 
internal readonly record struct Pipeline(
    PipelineMode Mode,
    Query Query,
    Type ElemType,
    bool ElemNullable,
    ISerializer? ElemSerializer,
    LambdaExpression? ProjectExpr)
{
    public IPipelineExecutor GetExec(DataContext ctx)
    {
        var ser = ElemSerializer ??
            (ElemNullable ?
             Serializer.GenerateNullable(ctx.MappingCtx, ElemType) :
             Serializer.Generate(ctx.MappingCtx, ElemType));
 
        var proj = ProjectExpr?.Compile();
 
        return IPipelineExecutor.Create(ctx, Query, ser, proj, Mode);
    }
}