18778187096

Committed 24 Oct 2025 11:14AM UTC coverage: 83.295% (-0.2%) from 83.516%

Build # 18778187096

Build Type

push

github

Committed by

lucaslorentz

Commit Message

Move IncrementalContext param into Input param

Run Details

56 of 58 new or added lines in 22 files covered. (96.55%)

8 existing lines in 5 files now uncovered.

1790 of 2149 relevant lines covered (83.29%)

880.64 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

76.92

/src/LLL.AutoCompute.EFCore/Metadata/Internal/ComputedObserver.cs

using LLL.AutoCompute.EFCore.Internal;

namespace LLL.AutoCompute.EFCore.Metadata.Internal;

public abstract class ComputedObserver(
    IComputedChangesProvider changesProvider)
    : ComputedBase(changesProvider)
{
    public abstract Task<Func<Task>?> CreateObserverNotifier(EFCoreComputedInput input);
}

public class ComputedObserver<TEntity, TChange>(
    IComputedChangesProvider<EFCoreComputedInput, TEntity, TChange> changesProvider,
    Func<ComputedChangeEventData<TEntity, TChange>, Task> callback
) : ComputedObserver(changesProvider)
    where TEntity : class
{
    public new IComputedChangesProvider<EFCoreComputedInput, TEntity, TChange> ChangesProvider => changesProvider;

    public override string ToDebugString()
    {
        return "ComputedObserver";
    }

    public override async Task<Func<Task>?> CreateObserverNotifier(EFCoreComputedInput input)
    {
        var changes = await changesProvider.GetChangesAsync(input, null);
        if (changes.Count == 0)
            return null;

        var eventData = new ComputedChangeEventData<TEntity, TChange>
        {
            DbContext = input.DbContext,
            Changes = changes
        };

        return () => callback(eventData);
    }
}

1	using LLL.AutoCompute.EFCore.Internal;
2
3	namespace LLL.AutoCompute.EFCore.Metadata.Internal;
4
5	public abstract class ComputedObserver(
6	IComputedChangesProvider changesProvider)
7	: ComputedBase(changesProvider)	12✔
8	{
9	public abstract Task<Func<Task>?> CreateObserverNotifier(EFCoreComputedInput input);
10	}
11
12	public class ComputedObserver<TEntity, TChange>(
13	IComputedChangesProvider<EFCoreComputedInput, TEntity, TChange> changesProvider,
14	Func<ComputedChangeEventData<TEntity, TChange>, Task> callback
15	) : ComputedObserver(changesProvider)	12✔
16	where TEntity : class
17	{
NEW 18	public new IComputedChangesProvider<EFCoreComputedInput, TEntity, TChange> ChangesProvider => changesProvider;	×
19
20	public override string ToDebugString()
21	{
22	return "ComputedObserver";	×
23	}
24
25	public override async Task<Func<Task>?> CreateObserverNotifier(EFCoreComputedInput input)
26	{
27	var changes = await changesProvider.GetChangesAsync(input, null);	24✔
28	if (changes.Count == 0)	24✔
29	return null;	×
30
31	var eventData = new ComputedChangeEventData<TEntity, TChange>	24✔
32	{	24✔
33	DbContext = input.DbContext,	24✔
34	Changes = changes	24✔
35	};	24✔
36
37	return () => callback(eventData);	48✔
38	}
39	}

lucaslorentz / auto-compute / 18778187096

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous