-
-
Notifications
You must be signed in to change notification settings - Fork 182
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into feature/changeset-as-observable-optional
- Loading branch information
Showing
7 changed files
with
1,576 additions
and
1 deletion.
There are no files selected for viewing
174 changes: 174 additions & 0 deletions
174
src/DynamicData.Tests/Cache/EditDiffChangeSetFixture.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,174 @@ | ||
using System; | ||
using System.Collections.Generic; | ||
using System.Diagnostics; | ||
using System.Linq; | ||
using System.Reactive.Linq; | ||
using FluentAssertions; | ||
|
||
using Xunit; | ||
|
||
namespace DynamicData.Tests.Cache; | ||
|
||
public class EditDiffChangeSetFixture | ||
{ | ||
private const int MaxItems = 1097; | ||
|
||
[Fact] | ||
public void NullChecksArePerformed() | ||
{ | ||
Assert.Throws<ArgumentNullException>(() => Observable.Empty<IEnumerable<Person>>().EditDiff<Person, int>(null!)); | ||
Assert.Throws<ArgumentNullException>(() => default(IObservable<IEnumerable<Person>>)!.EditDiff<Person, int>(null!)); | ||
} | ||
|
||
[Fact] | ||
public void ItemsFromEnumerableAreAddedToChangeSet() | ||
{ | ||
// having | ||
var enumerable = CreatePeople(0, MaxItems, "Name"); | ||
var enumObservable = Observable.Return(enumerable); | ||
|
||
// when | ||
var observableChangeSet = enumObservable.EditDiff(p => p.Id); | ||
using var results = observableChangeSet.AsAggregator(); | ||
|
||
// then | ||
results.Data.Count.Should().Be(MaxItems); | ||
results.Messages.Count.Should().Be(1); | ||
} | ||
|
||
[Fact] | ||
public void ItemsRemovedFromEnumerableAreRemovedFromChangeSet() | ||
{ | ||
// having | ||
var enumerable = CreatePeople(0, MaxItems, "Name"); | ||
var enumObservable = new[] {enumerable, Enumerable.Empty<Person>()}.ToObservable(); | ||
|
||
// when | ||
var observableChangeSet = enumObservable.EditDiff(p => p.Id); | ||
using var results = observableChangeSet.AsAggregator(); | ||
|
||
// then | ||
results.Data.Count.Should().Be(0); | ||
results.Messages.Count.Should().Be(2); | ||
results.Messages[0].Adds.Should().Be(MaxItems); | ||
results.Messages[1].Removes.Should().Be(MaxItems); | ||
results.Messages[1].Updates.Should().Be(0); | ||
} | ||
|
||
[Fact] | ||
public void ItemsUpdatedAreUpdatedInChangeSet() | ||
{ | ||
// having | ||
var enumerable1 = CreatePeople(0, MaxItems * 2, "Name"); | ||
var enumerable2 = CreatePeople(MaxItems, MaxItems, "Update"); | ||
var enumObservable = new[] { enumerable1, enumerable2 }.ToObservable(); | ||
|
||
// when | ||
var observableChangeSet = enumObservable.EditDiff(p => p.Id); | ||
using var results = observableChangeSet.AsAggregator(); | ||
|
||
// then | ||
results.Data.Count.Should().Be(MaxItems); | ||
results.Messages.Count.Should().Be(2); | ||
results.Messages[0].Adds.Should().Be(MaxItems * 2); | ||
results.Messages[1].Updates.Should().Be(MaxItems); | ||
results.Messages[1].Removes.Should().Be(MaxItems); | ||
} | ||
|
||
[Theory] | ||
[InlineData(true)] | ||
[InlineData(false)] | ||
public void ResultCompletesIfAndOnlyIfSourceCompletes(bool completeSource) | ||
{ | ||
// having | ||
var enumerable = CreatePeople(0, MaxItems, "Name"); | ||
var enumObservable = Observable.Return(enumerable); | ||
if (!completeSource) | ||
{ | ||
enumObservable = enumObservable.Concat(Observable.Never<IEnumerable<Person>>()); | ||
} | ||
bool completed = false; | ||
|
||
// when | ||
using var results = enumObservable.Subscribe(_ => { }, () => completed = true); | ||
|
||
// then | ||
completed.Should().Be(completeSource); | ||
} | ||
|
||
[Theory] | ||
[InlineData(true)] | ||
[InlineData(false)] | ||
public void ResultFailsIfAndOnlyIfSourceFails (bool failSource) | ||
{ | ||
// having | ||
var enumerable = CreatePeople(0, MaxItems, "Name"); | ||
var enumObservable = Observable.Return(enumerable); | ||
var testException = new Exception("Test"); | ||
if (failSource) | ||
{ | ||
enumObservable = enumObservable.Concat(Observable.Throw<IEnumerable<Person>>(testException)); | ||
} | ||
var receivedError = default(Exception); | ||
|
||
// when | ||
using var results = enumObservable.Subscribe(_ => { }, err => receivedError = err); | ||
|
||
// then | ||
receivedError.Should().Be(failSource ? testException : default); | ||
} | ||
|
||
[Trait("Performance", "Manual run only")] | ||
[Theory] | ||
[InlineData(7, 3, 5)] | ||
[InlineData(233, 113, MaxItems)] | ||
[InlineData(233, 0, MaxItems)] | ||
[InlineData(233, 233, MaxItems)] | ||
[InlineData(2521, 1187, MaxItems)] | ||
[InlineData(2521, 0, MaxItems)] | ||
[InlineData(2521, 2521, MaxItems)] | ||
[InlineData(5081, 2683, MaxItems)] | ||
[InlineData(5081, 0, MaxItems)] | ||
[InlineData(5081, 5081, MaxItems)] | ||
public void Perf(int collectionSize, int updateSize, int maxItems) | ||
{ | ||
Debug.Assert(updateSize <= collectionSize); | ||
|
||
// having | ||
var enumerables = Enumerable.Range(1, maxItems - 1) | ||
.Select(n => n * (collectionSize - updateSize)) | ||
.Select(index => CreatePeople(index, updateSize, "Overlap") | ||
.Concat(CreatePeople(index + updateSize, collectionSize - updateSize, "Name"))) | ||
.Prepend(CreatePeople(0, collectionSize, "Name")); | ||
var enumObservable = enumerables.ToObservable(); | ||
|
||
// when | ||
var observableChangeSet = enumObservable.EditDiff(p => p.Id); | ||
using var results = observableChangeSet.AsAggregator(); | ||
|
||
// then | ||
results.Data.Count.Should().Be(collectionSize); | ||
results.Messages.Count.Should().Be(maxItems); | ||
results.Summary.Overall.Adds.Should().Be((collectionSize * maxItems) - (updateSize * (maxItems - 1))); | ||
results.Summary.Overall.Removes.Should().Be((collectionSize - updateSize) * (maxItems - 1)); | ||
results.Summary.Overall.Updates.Should().Be(updateSize * (maxItems - 1)); | ||
} | ||
|
||
private static Person CreatePerson(int id, string name) => new(id, name); | ||
|
||
private static IEnumerable<Person> CreatePeople(int baseId, int count, string baseName) => | ||
Enumerable.Range(baseId, count).Select(i => CreatePerson(i, baseName + i)); | ||
|
||
private class Person | ||
{ | ||
public Person(int id, string name) | ||
{ | ||
Id = id; | ||
Name = name; | ||
} | ||
|
||
public int Id { get; } | ||
|
||
public string Name { get; } | ||
} | ||
} |
Oops, something went wrong.