diff --git a/Directory.Packages.props b/Directory.Packages.props
index 664aeee1..c66345b6 100644
--- a/Directory.Packages.props
+++ b/Directory.Packages.props
@@ -13,7 +13,7 @@
9.0.3
- 0.25.21
+ 0.77.3
@@ -33,7 +33,7 @@
-
+
@@ -84,8 +84,8 @@
-
-
+
+
@@ -93,12 +93,12 @@
-
-
-
-
-
-
+
+
+
+
+
+
diff --git a/src/Azure/test/Eventuous.Tests.Azure.ServiceBus/TopicAndQueueSourceAttribute.cs b/src/Azure/test/Eventuous.Tests.Azure.ServiceBus/TopicAndQueueSourceAttribute.cs
index ddcdf923..945373b0 100644
--- a/src/Azure/test/Eventuous.Tests.Azure.ServiceBus/TopicAndQueueSourceAttribute.cs
+++ b/src/Azure/test/Eventuous.Tests.Azure.ServiceBus/TopicAndQueueSourceAttribute.cs
@@ -7,19 +7,15 @@ public class TopicAndQueueSourceAttribute : DataSourceGeneratorAttribute
- /// This is strange. The 'subscription.1' in the emulator has a content type filter. We populate
- /// the content type, but it still gets filtered out. So we use 'subscription.3,' which has no filters.
- ///
+ // This is strange. The 'subscription.1' in the emulator has a content type filter. We populate
+ // the content type, but it still gets filtered out. So we use 'subscription.3,' which has no filters.
const string SubscriptionName = "subscription.3";
- readonly ClassDataSourceAttribute _fixtureDataSource = new() {
- Shared = SharedType.PerTestSession
- };
+ static readonly Lazy FixtureInstance = new(() => new());
- public override IEnumerable> GenerateDataSources(DataGeneratorMetadata dataGeneratorMetadata) {
+ protected override IEnumerable> GenerateDataSources(DataGeneratorMetadata dataGeneratorMetadata) {
yield return () => {
- var f = _fixtureDataSource.GenerateDataSources(dataGeneratorMetadata).First()();
+ var f = FixtureInstance.Value;
return (
f,
@@ -34,7 +30,7 @@ public class TopicAndQueueSourceAttribute : DataSourceGeneratorAttribute {
- var f = _fixtureDataSource.GenerateDataSources(dataGeneratorMetadata).First()();
+ var f = FixtureInstance.Value;
return (
f,
@@ -49,7 +45,7 @@ public class TopicAndQueueSourceAttribute : DataSourceGeneratorAttribute {
- var f = _fixtureDataSource.GenerateDataSources(dataGeneratorMetadata).First()();
+ var f = FixtureInstance.Value;
return (
f,
diff --git a/src/Core/test/Eventuous.Tests.Persistence.Base/Store/Append.cs b/src/Core/test/Eventuous.Tests.Persistence.Base/Store/Append.cs
index e12916e5..3c796e36 100644
--- a/src/Core/test/Eventuous.Tests.Persistence.Base/Store/Append.cs
+++ b/src/Core/test/Eventuous.Tests.Persistence.Base/Store/Append.cs
@@ -1,6 +1,5 @@
using Eventuous.Sut.Domain;
using Eventuous.Tests.Persistence.Base.Fixtures;
-using TUnit.Assertions.AssertConditions.Throws;
namespace Eventuous.Tests.Persistence.Base.Store;
@@ -48,7 +47,7 @@ public async Task ShouldFailOnWrongVersionNoStream() {
evt = Helpers.CreateEvent();
- await Assert.That(() => _fixture.AppendEvent(stream, evt, ExpectedStreamVersion.NoStream)).Throws();
+ await Assert.That(() => _fixture.AppendEvent(stream, evt, ExpectedStreamVersion.NoStream)!).Throws();
}
[Test]
@@ -61,9 +60,9 @@ public async Task ShouldFailOnWrongVersion() {
evt = Helpers.CreateEvent();
- await Assert.That(() => _fixture.AppendEvent(stream, evt, new(3))).Throws();
+ await Assert.That(() => _fixture.AppendEvent(stream, evt, new(3))!).Throws();
}
-
+
[Test]
[Category("Store")]
@@ -75,6 +74,6 @@ public async Task ShouldFailOnWrongVersionWithOptimisticConcurrencyException() {
evt = Helpers.CreateEvent();
- await Assert.That(() => _fixture.StoreChanges(stream, evt, new(3))).Throws();
+ await Assert.That(() => _fixture.StoreChanges(stream, evt, new(3))!).Throws();
}
}
diff --git a/src/Core/test/Eventuous.Tests.Persistence.Base/Store/Read.cs b/src/Core/test/Eventuous.Tests.Persistence.Base/Store/Read.cs
index bb29cfc2..dbc02c69 100644
--- a/src/Core/test/Eventuous.Tests.Persistence.Base/Store/Read.cs
+++ b/src/Core/test/Eventuous.Tests.Persistence.Base/Store/Read.cs
@@ -34,7 +34,8 @@ public async Task ShouldReadMany(CancellationToken cancellationToken) {
await _fixture.AppendEvents(streamName, events, ExpectedStreamVersion.NoStream);
var result = await _fixture.EventStore.ReadEvents(streamName, StreamReadPosition.Start, 100, true, cancellationToken);
- var actual = result.Select(x => x.Payload);
+
+ IEnumerable