New Filter Operators: #758

[JakenVeina]

Added new Filter operators that utilize a predicate state stream, to help avoid unneccessary allocations of a new filter predicate delegate, every time the consumer desires to change filtering logic.

public static IObservable<IChangeSet<TObject, TKey>> Filter<TObject, TKey, TState>(
        this    IObservable<IChangeSet<TObject, TKey>>  source,
                IObservable<TState>                     predicateState,
                Func<TState, TObject, bool>             predicate,
                bool                                    suppressEmptyChangeSets = true)
    where TObject : notnull
    where TKey : notnull

Method	Mean	Error	StdDev	Ratio	Allocated	Alloc Ratio
RandomizedEditsAndStateChanges	345.4 ms	6.90 ms	17.80 ms	1.00	8.57 MB	1.00

public static IObservable<IChangeSet<T>> Filter<T, TState>(
        this    IObservable<IChangeSet<T>>  source,
                IObservable<TState>         predicateState,
                Func<TState, T, bool>       predicate,
                ListFilterPolicy            filterPolicy            = ListFilterPolicy.CalculateDiff,
                bool                        suppressEmptyChangeSets = true)
    where T : notnull

Method	FilterPolicy	Mean	Error	StdDev	Ratio	Allocated	Alloc Ratio
RandomizedEditsAndStateChanges	ClearAndReplace	26.37 ms	0.510 ms	0.663 ms	1.00	1.88 MB	1.00
RandomizedEditsAndStateChanges	CalculateDiff	43.68 ms	0.868 ms	1.673 ms	1.00	3.63 MB	1.00

[github-actions]

This pull request has been automatically locked since there has not been any recent activity after it was closed. Please open a new issue for related bugs.