This is an automated email from the ASF dual-hosted git repository.
blankensteiner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-dotpulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 0916a5d Someone from FluentAssertions forgot to assert that
license.Should().BeFree() so welcome back Shouldly
0916a5d is described below
commit 0916a5d53ab69c330eec14410aa2cec884a7053b
Author: Daniel Blankensteiner <[email protected]>
AuthorDate: Mon Jan 27 17:23:48 2025 +0100
Someone from FluentAssertions forgot to assert that
license.Should().BeFree() so welcome back Shouldly
---
tests/DotPulsar.Tests/DotPulsar.Tests.csproj | 4 +-
.../Extensions/ReceiveExtensionsTests.cs | 4 +-
.../Extensions/StateExtensionsTests.cs | 20 ++--
.../Extensions/StateHolderExtensionsTests.cs | 12 +--
tests/DotPulsar.Tests/Internal/AsyncLockTests.cs | 14 +--
tests/DotPulsar.Tests/Internal/AsyncQueueTests.cs | 16 +--
.../Internal/AsyncQueueWithCursorTests.cs | 90 ++++++++---------
.../Internal/ChunkingPipelineTests.cs | 16 +--
.../Compression/BuiltinZlibCompressionTests.cs | 4 +-
.../Internal/Compression/Lz4CompressionTests.cs | 4 +-
.../Internal/Compression/SnappyCompressionTests.cs | 4 +-
.../Internal/Compression/ZstdCompressionTests.cs | 4 +-
.../Compression/ZstdSharpCompressionTests.cs | 4 +-
tests/DotPulsar.Tests/Internal/ConsumerTests.cs | 24 ++---
tests/DotPulsar.Tests/Internal/Crc32CTests.cs | 4 +-
.../Extensions/ReadOnlySequenceExtensionsTests.cs | 20 ++--
.../Internal/MessageProcessorTests.cs | 6 +-
.../Internal/PingPongHandlerTest.cs | 6 +-
tests/DotPulsar.Tests/Internal/ProducerTests.cs | 30 +++---
tests/DotPulsar.Tests/Internal/ReaderTests.cs | 24 ++---
.../Internal/RoundRobinPartitionRouterTests.cs | 4 +-
.../Internal/SequenceBuilderTests.cs | 14 +--
tests/DotPulsar.Tests/Internal/SerializerTests.cs | 2 +-
.../Internal/SinglePartitionRouterTests.cs | 4 +-
.../DotPulsar.Tests/Internal/StateManagerTests.cs | 26 ++---
tests/DotPulsar.Tests/MessageIdTests.cs | 110 ++++++++++-----------
tests/DotPulsar.Tests/PulsarClientTests.cs | 14 +--
27 files changed, 242 insertions(+), 242 deletions(-)
diff --git a/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
b/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
index dc7d31d..09db91f 100644
--- a/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
+++ b/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
@@ -9,8 +9,8 @@
</PropertyGroup>
<ItemGroup>
- <Using Include="FluentAssertions" />
<Using Include="NSubstitute" />
+ <Using Include="Shouldly" />
<Using Include="Xunit" />
</ItemGroup>
@@ -21,11 +21,11 @@
<PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers;
buildtransitive</IncludeAssets>
</PackageReference>
- <PackageReference Include="FluentAssertions" Version="7.1.0" />
<PackageReference Include="IronSnappy" Version="1.3.1" />
<PackageReference Include="K4os.Compression.LZ4" Version="1.3.8" />
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.12.0" />
<PackageReference Include="NSubstitute" Version="5.3.0" />
+ <PackageReference Include="Shouldly" Version="4.3.0" />
<PackageReference Include="Testcontainers" Version="4.1.0" />
<PackageReference Include="Testcontainers.Pulsar" Version="4.1.0" />
<PackageReference Include="ToxiproxyNetCore" Version="1.0.35" />
diff --git a/tests/DotPulsar.Tests/Extensions/ReceiveExtensionsTests.cs
b/tests/DotPulsar.Tests/Extensions/ReceiveExtensionsTests.cs
index 876b050..a5e875e 100644
--- a/tests/DotPulsar.Tests/Extensions/ReceiveExtensionsTests.cs
+++ b/tests/DotPulsar.Tests/Extensions/ReceiveExtensionsTests.cs
@@ -49,7 +49,7 @@ public class ReceiveExtensionsTests
var actual = receiver.TryReceive(out var message);
//Assert
- actual.Should().BeTrue();
+ actual.ShouldBe(true);
}
[Fact]
@@ -63,7 +63,7 @@ public class ReceiveExtensionsTests
var actual = receiver.TryReceive(out var message);
//Assert
- actual.Should().BeFalse();
+ actual.ShouldBe(false);
}
private static string CreateSubscriptionName() =>
$"subscription-{Guid.NewGuid():N}";
diff --git a/tests/DotPulsar.Tests/Extensions/StateExtensionsTests.cs
b/tests/DotPulsar.Tests/Extensions/StateExtensionsTests.cs
index 376c455..7f76759 100644
--- a/tests/DotPulsar.Tests/Extensions/StateExtensionsTests.cs
+++ b/tests/DotPulsar.Tests/Extensions/StateExtensionsTests.cs
@@ -35,7 +35,7 @@ public class StateExtensionsTests
var actual = await uut.OnStateChangeTo(ProducerState.Disconnected,
TimeSpan.FromSeconds(1));
// Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Theory, Tests.AutoData]
@@ -52,7 +52,7 @@ public class StateExtensionsTests
var actual = await uut.OnStateChangeTo(ProducerState.Disconnected,
TimeSpan.FromSeconds(1));
// Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Theory, Tests.AutoData]
@@ -68,7 +68,7 @@ public class StateExtensionsTests
var actual = await uut.OnStateChangeTo(expected,
TimeSpan.FromSeconds(1));
// Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Theory, Tests.AutoData]
@@ -83,7 +83,7 @@ public class StateExtensionsTests
var exception = await Record.ExceptionAsync(() =>
uut.OnStateChangeTo(ProducerState.Disconnected, TimeSpan.FromSeconds(1),
cts.Token).AsTask());
// Assert
- exception.Should().BeOfType<OperationCanceledException>();
+ exception.ShouldBeOfType<OperationCanceledException>();
}
[Theory, Tests.AutoData]
@@ -100,7 +100,7 @@ public class StateExtensionsTests
var exception = await Record.ExceptionAsync(() =>
uut.OnStateChangeTo(ProducerState.Disconnected, TimeSpan.FromSeconds(1),
cts.Token).AsTask());
// Assert
- exception.Should().BeOfType<OperationCanceledException>();
+ exception.ShouldBeOfType<OperationCanceledException>();
}
[Theory, Tests.AutoData]
@@ -115,7 +115,7 @@ public class StateExtensionsTests
var actual = await uut.OnStateChangeFrom(ProducerState.Disconnected,
TimeSpan.FromSeconds(1));
// Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Theory, Tests.AutoData]
@@ -132,7 +132,7 @@ public class StateExtensionsTests
var actual = await uut.OnStateChangeFrom(ProducerState.Disconnected,
TimeSpan.FromSeconds(1));
// Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Theory, Tests.AutoData]
@@ -148,7 +148,7 @@ public class StateExtensionsTests
var actual = await uut.OnStateChangeFrom(ProducerState.Connected,
TimeSpan.FromSeconds(1));
// Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Theory, Tests.AutoData]
@@ -163,7 +163,7 @@ public class StateExtensionsTests
var exception = await Record.ExceptionAsync(() =>
uut.OnStateChangeFrom(ProducerState.Disconnected, TimeSpan.FromSeconds(1),
cts.Token).AsTask());
// Assert
- exception.Should().BeOfType<OperationCanceledException>();
+ exception.ShouldBeOfType<OperationCanceledException>();
}
[Theory, Tests.AutoData]
@@ -180,6 +180,6 @@ public class StateExtensionsTests
var exception = await Record.ExceptionAsync(() =>
uut.OnStateChangeFrom(ProducerState.Disconnected, TimeSpan.FromSeconds(1),
cts.Token).AsTask());
// Assert
- exception.Should().BeOfType<OperationCanceledException>();
+ exception.ShouldBeOfType<OperationCanceledException>();
}
}
diff --git a/tests/DotPulsar.Tests/Extensions/StateHolderExtensionsTests.cs
b/tests/DotPulsar.Tests/Extensions/StateHolderExtensionsTests.cs
index e36e960..ad3b4b6 100644
--- a/tests/DotPulsar.Tests/Extensions/StateHolderExtensionsTests.cs
+++ b/tests/DotPulsar.Tests/Extensions/StateHolderExtensionsTests.cs
@@ -38,9 +38,9 @@ public class StateHolderExtensionsTests
await uut.DelayedStateMonitor(ProducerState.Connected,
TimeSpan.FromSeconds(1), onStateLeft, onStateReached);
// Assert
- stateLeft.HasValue.Should().BeTrue();
- stateLeft!.Value.Should().Be(expected);
- stateReached.HasValue.Should().BeFalse();
+ stateLeft.HasValue.ShouldBeTrue();
+ stateLeft!.Value.ShouldBe(expected);
+ stateReached.HasValue.ShouldBeFalse();
}
[Theory, Tests.AutoData]
@@ -61,8 +61,8 @@ public class StateHolderExtensionsTests
await uut.DelayedStateMonitor(ProducerState.Connected,
TimeSpan.FromSeconds(1), onStateLeft, onStateReached);
// Assert
- stateLeft.HasValue.Should().BeTrue();
- stateLeft!.Value.Should().Be(expected);
- stateReached.HasValue.Should().BeFalse();
+ stateLeft.HasValue.ShouldBeTrue();
+ stateLeft!.Value.ShouldBe(expected);
+ stateReached.HasValue.ShouldBeFalse();
}
}
diff --git a/tests/DotPulsar.Tests/Internal/AsyncLockTests.cs
b/tests/DotPulsar.Tests/Internal/AsyncLockTests.cs
index 902ce9d..d4b8932 100644
--- a/tests/DotPulsar.Tests/Internal/AsyncLockTests.cs
+++ b/tests/DotPulsar.Tests/Internal/AsyncLockTests.cs
@@ -30,7 +30,7 @@ public class AsyncLockTests
var actual = sut.Lock(CancellationToken.None);
//Assert
- actual.IsCompleted.Should().BeTrue();
+ actual.IsCompleted.ShouldBeTrue();
//Annihilate
(await actual).Dispose();
@@ -47,7 +47,7 @@ public class AsyncLockTests
var actual = sut.Lock(CancellationToken.None);
//Assert
- actual.IsCompleted.Should().BeFalse();
+ actual.IsCompleted.ShouldBeFalse();
//Annihilate
alreadyTaken.Dispose();
@@ -65,7 +65,7 @@ public class AsyncLockTests
var exception = await Record.ExceptionAsync(() =>
sut.Lock(CancellationToken.None));
//Assert
- exception.Should().BeOfType<AsyncLockDisposedException>();
+ exception.ShouldBeOfType<AsyncLockDisposedException>();
}
[Fact]
@@ -81,7 +81,7 @@ public class AsyncLockTests
var exception = await Record.ExceptionAsync(() => awaiting);
//Assert
- exception.Should().BeOfType<TaskCanceledException>();
+ exception.ShouldBeOfType<TaskCanceledException>();
//Annihilate
await sut.DisposeAsync();
@@ -102,7 +102,7 @@ public class AsyncLockTests
var exception = await Record.ExceptionAsync(() => awaiting);
//Assert
- exception.Should().BeOfType<TaskCanceledException>();
+ exception.ShouldBeOfType<TaskCanceledException>();
//Annihilate
cts.Dispose();
@@ -124,7 +124,7 @@ public class AsyncLockTests
await disposeTask;
//Assert
- disposeTask.IsCompleted.Should().BeTrue();
+ disposeTask.IsCompleted.ShouldBeTrue();
//Annihilate
await sut.DisposeAsync();
@@ -141,6 +141,6 @@ public class AsyncLockTests
var exception = await Record.ExceptionAsync(() =>
sut.DisposeAsync().AsTask()); // xUnit can't record ValueTask yet
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
}
diff --git a/tests/DotPulsar.Tests/Internal/AsyncQueueTests.cs
b/tests/DotPulsar.Tests/Internal/AsyncQueueTests.cs
index 7496336..18fbe24 100644
--- a/tests/DotPulsar.Tests/Internal/AsyncQueueTests.cs
+++ b/tests/DotPulsar.Tests/Internal/AsyncQueueTests.cs
@@ -32,7 +32,7 @@ public class AsyncQueueTests
var actual = await dequeueTask;
//Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
//Annihilate
queue.Dispose();
@@ -50,7 +50,7 @@ public class AsyncQueueTests
var actual = await queue.Dequeue();
//Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
//Annihilate
queue.Dispose();
@@ -72,8 +72,8 @@ public class AsyncQueueTests
var actual2 = await dequeue2;
//Assert
- actual1.Should().Be(expected1);
- actual2.Should().Be(expected2);
+ actual1.ShouldBe(expected1);
+ actual2.ShouldBe(expected2);
//Annihilate
queue.Dispose();
@@ -93,8 +93,8 @@ public class AsyncQueueTests
var actual2 = await queue.Dequeue();
//Assert
- actual1.Should().Be(expected1);
- actual2.Should().Be(expected2);
+ actual1.ShouldBe(expected1);
+ actual2.ShouldBe(expected2);
//Annihilate
queue.Dispose();
@@ -117,8 +117,8 @@ public class AsyncQueueTests
var actual = await task2;
//Assert
- exception.Should().BeOfType<TaskCanceledException>();
- actual.Should().Be(excepted);
+ exception.ShouldBeOfType<TaskCanceledException>();
+ actual.ShouldBe(excepted);
//Annihilate
source1.Dispose();
diff --git a/tests/DotPulsar.Tests/Internal/AsyncQueueWithCursorTests.cs
b/tests/DotPulsar.Tests/Internal/AsyncQueueWithCursorTests.cs
index 53a3e8f..8c78ab0 100644
--- a/tests/DotPulsar.Tests/Internal/AsyncQueueWithCursorTests.cs
+++ b/tests/DotPulsar.Tests/Internal/AsyncQueueWithCursorTests.cs
@@ -31,7 +31,7 @@ public class AsyncQueueWithCursorTests
var actual = sut.TryPeek(out _);
//Assert
- actual.Should().BeFalse();
+ actual.ShouldBeFalse();
//Annihilate
await sut.DisposeAsync();
@@ -49,9 +49,9 @@ public class AsyncQueueWithCursorTests
var actual = sut.TryPeek(out var result);
//Assert
- actual.Should().BeTrue();
- result.Should().NotBeNull();
- result!.Should().Be(expected);
+ actual.ShouldBeTrue();
+ result.ShouldNotBeNull();
+ result!.ShouldBe(expected);
//Annihilate
await sut.DisposeAsync();
@@ -69,7 +69,7 @@ public class AsyncQueueWithCursorTests
var actual = sut.TryPeek(out _);
//Assert
- actual.Should().BeFalse();
+ actual.ShouldBeFalse();
//Annihilate
await sut.DisposeAsync();
@@ -85,7 +85,7 @@ public class AsyncQueueWithCursorTests
var act = () => sut.Dequeue();
//Assert
- act.Should().Throw<InvalidOperationException>();
+ act.ShouldThrow<InvalidOperationException>();
//Annihilate
await sut.DisposeAsync();
@@ -103,9 +103,9 @@ public class AsyncQueueWithCursorTests
var actual = sut.TryPeek(out var result);
//Assert
- actual.Should().BeTrue();
- result.Should().NotBeNull();
- result!.Should().Be(expected);
+ actual.ShouldBeTrue();
+ result.ShouldNotBeNull();
+ result!.ShouldBe(expected);
//Annihilate
await sut.DisposeAsync();
@@ -122,9 +122,9 @@ public class AsyncQueueWithCursorTests
var actual = sut.Enqueue(Substitute.For<IDisposable>(),
CancellationToken.None);
//Assert
- actual.IsCompleted.Should().BeFalse();
- actual.IsFaulted.Should().BeFalse();
- actual.IsCanceled.Should().BeFalse();
+ actual.IsCompleted.ShouldBeFalse();
+ actual.IsFaulted.ShouldBeFalse();
+ actual.IsCanceled.ShouldBeFalse();
//Annihilate
await sut.DisposeAsync();
@@ -145,9 +145,9 @@ public class AsyncQueueWithCursorTests
await pendingEnqueue;
//Assert
- pendingEnqueue.IsCompleted.Should().BeTrue();
- pendingEnqueue.IsFaulted.Should().BeFalse();
- pendingEnqueue.IsCanceled.Should().BeFalse();
+ pendingEnqueue.IsCompleted.ShouldBeTrue();
+ pendingEnqueue.IsFaulted.ShouldBeFalse();
+ pendingEnqueue.IsCanceled.ShouldBeFalse();
//Annihilate
cts.Dispose();
@@ -168,10 +168,10 @@ public class AsyncQueueWithCursorTests
var exception = await Record.ExceptionAsync(() => pendingEnqueue);
//Assert
- exception.Should().BeOfType<TaskCanceledException>();
- pendingEnqueue.IsCompleted.Should().BeTrue();
- pendingEnqueue.IsFaulted.Should().BeFalse();
- pendingEnqueue.IsCanceled.Should().BeTrue();
+ exception.ShouldBeOfType<TaskCanceledException>();
+ pendingEnqueue.IsCompleted.ShouldBeTrue();
+ pendingEnqueue.IsFaulted.ShouldBeFalse();
+ pendingEnqueue.IsCanceled.ShouldBeTrue();
//Annihilate
cts.Dispose();
@@ -193,8 +193,8 @@ public class AsyncQueueWithCursorTests
var actual2 = await sut.NextItem(CancellationToken.None);
//Assert
- actual1.Should().Be(expected1);
- actual2.Should().Be(expected2);
+ actual1.ShouldBe(expected1);
+ actual2.ShouldBe(expected2);
//Annihilate
await sut.DisposeAsync();
@@ -212,9 +212,9 @@ public class AsyncQueueWithCursorTests
var actual = sut.NextItem(CancellationToken.None);
//Assert
- actual.IsCompleted.Should().BeFalse();
- actual.IsFaulted.Should().BeFalse();
- actual.IsCanceled.Should().BeFalse();
+ actual.IsCompleted.ShouldBeFalse();
+ actual.IsFaulted.ShouldBeFalse();
+ actual.IsCanceled.ShouldBeFalse();
//Annihilate
await sut.DisposeAsync();
@@ -233,10 +233,10 @@ public class AsyncQueueWithCursorTests
var actual = await task;
//Assert
- actual.Should().Be(expected);
- task.IsCompleted.Should().BeTrue();
- task.IsFaulted.Should().BeFalse();
- task.IsCanceled.Should().BeFalse();
+ actual.ShouldBe(expected);
+ task.IsCompleted.ShouldBeTrue();
+ task.IsFaulted.ShouldBeFalse();
+ task.IsCanceled.ShouldBeFalse();
//Annihilate
await sut.DisposeAsync();
@@ -255,7 +255,7 @@ public class AsyncQueueWithCursorTests
var exception = await Record.ExceptionAsync(() => task.AsTask());
//Assert
- exception.Should().BeOfType<TaskCanceledException>();
+ exception.ShouldBeOfType<TaskCanceledException>();
}
[Fact]
@@ -275,8 +275,8 @@ public class AsyncQueueWithCursorTests
var after = await sut.NextItem(CancellationToken.None);
//Assert
- before.Should().Be(expected2);
- after.Should().Be(expected1);
+ before.ShouldBe(expected2);
+ after.ShouldBe(expected1);
//Annihilate
await sut.DisposeAsync();
@@ -292,7 +292,7 @@ public class AsyncQueueWithCursorTests
var exception = Record.Exception(() => sut.RemoveCurrentItem());
//Assert
- exception.Should().BeOfType<AsyncQueueWithCursorNoItemException>();
+ exception.ShouldBeOfType<AsyncQueueWithCursorNoItemException>();
//Annihilate
await sut.DisposeAsync();
@@ -309,7 +309,7 @@ public class AsyncQueueWithCursorTests
var exception = Record.Exception(() => sut.RemoveCurrentItem());
//Assert
- exception.Should().BeOfType<AsyncQueueWithCursorNoItemException>();
+ exception.ShouldBeOfType<AsyncQueueWithCursorNoItemException>();
//Annihilate
await sut.DisposeAsync();
@@ -327,7 +327,7 @@ public class AsyncQueueWithCursorTests
sut.RemoveCurrentItem();
//Assert
- sut.TryPeek(out _).Should().BeFalse();
+ sut.TryPeek(out _).ShouldBeFalse();
//Annihilate
await sut.DisposeAsync();
@@ -350,7 +350,7 @@ public class AsyncQueueWithCursorTests
var result = await sut.NextItem(CancellationToken.None);
//Assert
- result.Should().Be(expected);
+ result.ShouldBe(expected);
//Annihilate
await sut.DisposeAsync();
@@ -369,9 +369,9 @@ public class AsyncQueueWithCursorTests
var act = async () => await enqueueTask;
//Assert
- await act.Should().ThrowAsync<TaskCanceledException>();
- enqueueTask.IsCompleted.Should().BeTrue();
- enqueueTask.IsCanceled.Should().BeTrue();
+ await act.ShouldThrowAsync<TaskCanceledException>();
+ enqueueTask.IsCompleted.ShouldBeTrue();
+ enqueueTask.IsCanceled.ShouldBeTrue();
}
[Fact]
@@ -385,7 +385,7 @@ public class AsyncQueueWithCursorTests
var act = async () => await sut.Enqueue(Substitute.For<IDisposable>(),
CancellationToken.None);
//Assert
- await act.Should().ThrowAsync<AsyncLockDisposedException>();
+ await act.ShouldThrowAsync<AsyncLockDisposedException>();
}
[Fact]
@@ -400,9 +400,9 @@ public class AsyncQueueWithCursorTests
var act = async () => await nextItemTask;
//Assert
- await act.Should().ThrowAsync<TaskCanceledException>();
- nextItemTask.IsCompleted.Should().BeTrue();
- nextItemTask.IsCanceled.Should().BeTrue();
+ await act.ShouldThrowAsync<TaskCanceledException>();
+ nextItemTask.IsCompleted.ShouldBeTrue();
+ nextItemTask.IsCanceled.ShouldBeTrue();
}
[Fact]
@@ -418,9 +418,9 @@ public class AsyncQueueWithCursorTests
var act = async () => await waitForEmptyTask;
//Assert
- await act.Should().ThrowAsync<TaskCanceledException>();
- waitForEmptyTask.IsCompleted.Should().BeTrue();
- waitForEmptyTask.IsCanceled.Should().BeTrue();
+ await act.ShouldThrowAsync<TaskCanceledException>();
+ waitForEmptyTask.IsCompleted.ShouldBeTrue();
+ waitForEmptyTask.IsCanceled.ShouldBeTrue();
}
[Fact]
diff --git a/tests/DotPulsar.Tests/Internal/ChunkingPipelineTests.cs
b/tests/DotPulsar.Tests/Internal/ChunkingPipelineTests.cs
index 732a79a..3b69d32 100644
--- a/tests/DotPulsar.Tests/Internal/ChunkingPipelineTests.cs
+++ b/tests/DotPulsar.Tests/Internal/ChunkingPipelineTests.cs
@@ -39,8 +39,8 @@ public class ChunkingPipelineTests
//Assert
var expected = sequence.ToArray();
var actual = mockStream.GetReadOnlySequence();
- actual.ToArray().Should().Equal(expected);
- actual.IsSingleSegment.Should().BeTrue();
+ actual.ToArray().ShouldBe(expected);
+ actual.IsSingleSegment.ShouldBeTrue();
}
[Theory]
@@ -63,8 +63,8 @@ public class ChunkingPipelineTests
//Assert
var expected = sequence.ToArray();
var actual = mockStream.GetReadOnlySequence();
- actual.ToArray().Should().Equal(expected);
- GetNumberOfSegments(actual).Should().Be(expected3.HasValue ? 3 : 2);
+ actual.ToArray().ShouldBe(expected);
+ GetNumberOfSegments(actual).ShouldBe(expected3.HasValue ? 3 : 2);
var segmentNumber = 0;
foreach (var segment in actual)
@@ -72,14 +72,14 @@ public class ChunkingPipelineTests
switch (segmentNumber)
{
case 0:
- segment.Length.Should().Be(expected1);
+ segment.Length.ShouldBe(expected1);
break;
case 1:
- segment.Length.Should().Be(expected2);
+ segment.Length.ShouldBe(expected2);
break;
case 2:
- expected3.Should().NotBeNull();
- segment.Length.Should().Be(expected3);
+ expected3.ShouldNotBeNull();
+ segment.Length.ShouldBe(expected3.Value);
break;
}
++segmentNumber;
diff --git
a/tests/DotPulsar.Tests/Internal/Compression/BuiltinZlibCompressionTests.cs
b/tests/DotPulsar.Tests/Internal/Compression/BuiltinZlibCompressionTests.cs
index 360250d..e78abde 100644
--- a/tests/DotPulsar.Tests/Internal/Compression/BuiltinZlibCompressionTests.cs
+++ b/tests/DotPulsar.Tests/Internal/Compression/BuiltinZlibCompressionTests.cs
@@ -24,7 +24,7 @@ public class BuiltinZlibCompressionTests
{
// Arrange
var couldLoad = BuiltinZlibCompression.TryLoading(out var
compressorFactory, out var decompressorFactory);
- couldLoad.Should().BeTrue();
+ couldLoad.ShouldBeTrue();
using var compressor = compressorFactory!.Create();
using var decompressor = decompressorFactory!.Create();
@@ -32,6 +32,6 @@ public class BuiltinZlibCompressionTests
var compressionWorks =
CompressionTester.TestCompression(compressorFactory, decompressorFactory);
// Assert
- compressionWorks.Should().BeTrue();
+ compressionWorks.ShouldBeTrue();
}
}
diff --git a/tests/DotPulsar.Tests/Internal/Compression/Lz4CompressionTests.cs
b/tests/DotPulsar.Tests/Internal/Compression/Lz4CompressionTests.cs
index f4f016a..1122a14 100644
--- a/tests/DotPulsar.Tests/Internal/Compression/Lz4CompressionTests.cs
+++ b/tests/DotPulsar.Tests/Internal/Compression/Lz4CompressionTests.cs
@@ -24,7 +24,7 @@ public class Lz4CompressionTests
{
// Arrange
var couldLoad = Lz4Compression.TryLoading(out var compressorFactory,
out var decompressorFactory);
- couldLoad.Should().BeTrue();
+ couldLoad.ShouldBeTrue();
using var compressor = compressorFactory!.Create();
using var decompressor = decompressorFactory!.Create();
@@ -32,6 +32,6 @@ public class Lz4CompressionTests
var compressionWorks =
CompressionTester.TestCompression(compressorFactory, decompressorFactory);
// Assert
- compressionWorks.Should().BeTrue();
+ compressionWorks.ShouldBeTrue();
}
}
diff --git
a/tests/DotPulsar.Tests/Internal/Compression/SnappyCompressionTests.cs
b/tests/DotPulsar.Tests/Internal/Compression/SnappyCompressionTests.cs
index 3c90684..95b21a3 100644
--- a/tests/DotPulsar.Tests/Internal/Compression/SnappyCompressionTests.cs
+++ b/tests/DotPulsar.Tests/Internal/Compression/SnappyCompressionTests.cs
@@ -24,7 +24,7 @@ public class SnappyCompressionTests
{
// Arrange
var couldLoad = SnappyCompression.TryLoading(out var
compressorFactory, out var decompressorFactory);
- couldLoad.Should().BeTrue();
+ couldLoad.ShouldBeTrue();
using var compressor = compressorFactory!.Create();
using var decompressor = decompressorFactory!.Create();
@@ -32,6 +32,6 @@ public class SnappyCompressionTests
var compressionWorks =
CompressionTester.TestCompression(compressorFactory, decompressorFactory);
// Assert
- compressionWorks.Should().BeTrue();
+ compressionWorks.ShouldBeTrue();
}
}
diff --git a/tests/DotPulsar.Tests/Internal/Compression/ZstdCompressionTests.cs
b/tests/DotPulsar.Tests/Internal/Compression/ZstdCompressionTests.cs
index 064812a..daa63bc 100644
--- a/tests/DotPulsar.Tests/Internal/Compression/ZstdCompressionTests.cs
+++ b/tests/DotPulsar.Tests/Internal/Compression/ZstdCompressionTests.cs
@@ -24,7 +24,7 @@ public class ZstdCompressionTests
{
// Arrange
var couldLoad = ZstdCompression.TryLoading(out var compressorFactory,
out var decompressorFactory);
- couldLoad.Should().BeTrue();
+ couldLoad.ShouldBeTrue();
using var compressor = compressorFactory!.Create();
using var decompressor = decompressorFactory!.Create();
@@ -33,6 +33,6 @@ public class ZstdCompressionTests
var compressionWorks =
CompressionTester.TestCompression(compressorFactory, decompressorFactory);
// Assert
- compressionWorks.Should().BeTrue();
+ compressionWorks.ShouldBeTrue();
}
}
diff --git
a/tests/DotPulsar.Tests/Internal/Compression/ZstdSharpCompressionTests.cs
b/tests/DotPulsar.Tests/Internal/Compression/ZstdSharpCompressionTests.cs
index 489cdc3..882fad8 100644
--- a/tests/DotPulsar.Tests/Internal/Compression/ZstdSharpCompressionTests.cs
+++ b/tests/DotPulsar.Tests/Internal/Compression/ZstdSharpCompressionTests.cs
@@ -24,7 +24,7 @@ public class ZstdSharpCompressionTests
{
// Arrange
var couldLoad = ZstdSharpCompression.TryLoading(out var
compressorFactory, out var decompressorFactory);
- couldLoad.Should().BeTrue();
+ couldLoad.ShouldBeTrue();
using var compressor = compressorFactory!.Create();
using var decompressor = decompressorFactory!.Create();
@@ -32,6 +32,6 @@ public class ZstdSharpCompressionTests
var compressionWorks =
CompressionTester.TestCompression(compressorFactory, decompressorFactory);
// Assert
- compressionWorks.Should().BeTrue();
+ compressionWorks.ShouldBeTrue();
}
}
diff --git a/tests/DotPulsar.Tests/Internal/ConsumerTests.cs
b/tests/DotPulsar.Tests/Internal/ConsumerTests.cs
index 274e600..516bad4 100644
--- a/tests/DotPulsar.Tests/Internal/ConsumerTests.cs
+++ b/tests/DotPulsar.Tests/Internal/ConsumerTests.cs
@@ -58,7 +58,7 @@ public sealed class ConsumerTests : IDisposable
var actual = await consumer.GetLastMessageIds(_cts.Token);
//Assert
- actual.Should().BeEquivalentTo(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -87,7 +87,7 @@ public sealed class ConsumerTests : IDisposable
var actual = await consumer.GetLastMessageIds(_cts.Token);
//Assert
- actual.Should().BeEquivalentTo(expected);
+ actual.ShouldBeEquivalentTo(expected);
}
[Fact]
@@ -102,7 +102,7 @@ public sealed class ConsumerTests : IDisposable
var actual = await consumer.GetLastMessageIds(_cts.Token);
//Assert
- actual.Should().BeEquivalentTo(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -121,7 +121,7 @@ public sealed class ConsumerTests : IDisposable
var consumed = await ConsumeMessages(consumer, numberOfMessages,
_cts.Token);
//Assert
- consumed.Should().BeEquivalentTo(produced);
+ consumed.ShouldBe(produced);
}
[Fact]
@@ -142,7 +142,7 @@ public sealed class ConsumerTests : IDisposable
var consumed = await ConsumeMessages(consumer, numberOfMessages,
_cts.Token);
//Assert
- consumed.Should().BeEquivalentTo(produced);
+ consumed.ShouldBe(produced, true);
}
[Fact]
@@ -167,7 +167,7 @@ public sealed class ConsumerTests : IDisposable
var exception = await Record.ExceptionAsync(receiveTask.AsTask);
//Assert
- exception.Should().BeOfType<ConsumerFaultedException>();
+ exception.ShouldBeOfType<ConsumerFaultedException>();
}
[Fact]
@@ -189,7 +189,7 @@ public sealed class ConsumerTests : IDisposable
var exception = await
Record.ExceptionAsync(consumer.Receive(_cts.Token).AsTask);
//Assert
- exception.Should().BeOfType<ConsumerFaultedException>();
+ exception.ShouldBeOfType<ConsumerFaultedException>();
}
[Fact]
@@ -213,7 +213,7 @@ public sealed class ConsumerTests : IDisposable
var exception = await Record.ExceptionAsync(receiveTask.AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -233,7 +233,7 @@ public sealed class ConsumerTests : IDisposable
var exception = await
Record.ExceptionAsync(consumer.Receive(_cts.Token).AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -248,7 +248,7 @@ public sealed class ConsumerTests : IDisposable
var exception = await
Record.ExceptionAsync(consumer.DisposeAsync().AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -265,7 +265,7 @@ public sealed class ConsumerTests : IDisposable
var exception = await
Record.ExceptionAsync(consumer.DisposeAsync().AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -288,7 +288,7 @@ public sealed class ConsumerTests : IDisposable
var exception = await
Record.ExceptionAsync(consumer.Receive(_cts.Token).AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
private static async Task<IEnumerable<MessageId>>
ProduceMessages(IProducer<string> producer, int numberOfMessages, string
content, CancellationToken ct)
diff --git a/tests/DotPulsar.Tests/Internal/Crc32CTests.cs
b/tests/DotPulsar.Tests/Internal/Crc32CTests.cs
index b230cb8..223c7f2 100644
--- a/tests/DotPulsar.Tests/Internal/Crc32CTests.cs
+++ b/tests/DotPulsar.Tests/Internal/Crc32CTests.cs
@@ -32,7 +32,7 @@ public class Crc32CTests
//Assert
const uint expected = 2355953212;
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -55,6 +55,6 @@ public class Crc32CTests
//Assert
const uint expected = 1079987866;
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
}
diff --git
a/tests/DotPulsar.Tests/Internal/Extensions/ReadOnlySequenceExtensionsTests.cs
b/tests/DotPulsar.Tests/Internal/Extensions/ReadOnlySequenceExtensionsTests.cs
index 8cbe4f0..ed71e4c 100644
---
a/tests/DotPulsar.Tests/Internal/Extensions/ReadOnlySequenceExtensionsTests.cs
+++
b/tests/DotPulsar.Tests/Internal/Extensions/ReadOnlySequenceExtensionsTests.cs
@@ -30,7 +30,7 @@ public class ReadOnlySequenceExtensionsTests
var actual = sequence.StartsWith(new byte[] { 0x00, 0x01 });
//Assert
- actual.Should().BeFalse();
+ actual.ShouldBeFalse();
}
[Fact]
@@ -43,7 +43,7 @@ public class ReadOnlySequenceExtensionsTests
var actual = sequence.StartsWith(new byte[] { 0x00, 0x01 });
//Assert
- actual.Should().BeFalse();
+ actual.ShouldBeFalse();
}
[Fact]
@@ -56,7 +56,7 @@ public class ReadOnlySequenceExtensionsTests
var actual = sequence.StartsWith(new byte[] { 0x00, 0x01 });
//Assert
- actual.Should().BeTrue();
+ actual.ShouldBeTrue();
}
[Fact]
@@ -69,7 +69,7 @@ public class ReadOnlySequenceExtensionsTests
var actual = sequence.StartsWith(new byte[] { 0x00, 0x01, 0x02, 0x03
});
//Assert
- actual.Should().BeFalse();
+ actual.ShouldBeFalse();
}
[Fact]
@@ -82,7 +82,7 @@ public class ReadOnlySequenceExtensionsTests
var actual = sequence.StartsWith(new byte[] { 0x00, 0x01, 0x02 });
//Assert
- actual.Should().BeFalse();
+ actual.ShouldBeFalse();
}
[Fact]
@@ -95,7 +95,7 @@ public class ReadOnlySequenceExtensionsTests
var actual = sequence.StartsWith(new byte[] { 0x00, 0x01, 0x02 });
//Assert
- actual.Should().BeTrue();
+ actual.ShouldBeTrue();
}
[Fact]
@@ -109,7 +109,7 @@ public class ReadOnlySequenceExtensionsTests
//Assert
const uint expected = 66051;
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -123,7 +123,7 @@ public class ReadOnlySequenceExtensionsTests
//Assert
const uint expected = 66051;
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Theory]
@@ -155,7 +155,7 @@ public class ReadOnlySequenceExtensionsTests
//Assert
const uint expected = 0x02030405;
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Theory]
@@ -175,6 +175,6 @@ public class ReadOnlySequenceExtensionsTests
//Assert
const uint expected = 0x02030405;
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
}
diff --git a/tests/DotPulsar.Tests/Internal/MessageProcessorTests.cs
b/tests/DotPulsar.Tests/Internal/MessageProcessorTests.cs
index 69a7ba2..3ef99b0 100644
--- a/tests/DotPulsar.Tests/Internal/MessageProcessorTests.cs
+++ b/tests/DotPulsar.Tests/Internal/MessageProcessorTests.cs
@@ -51,7 +51,7 @@ public sealed class MessageProcessorTests : IDisposable
var exception = Record.Exception(() => new
MessageProcessor<byte[]>(consumer, ProcessMessage, options));
//Assert
- exception.Should().BeOfType<ProcessingException>();
+ exception.ShouldBeOfType<ProcessingException>();
}
[Theory, AutoData]
@@ -72,7 +72,7 @@ public sealed class MessageProcessorTests : IDisposable
_semaphore.Release();
//Assert
- _taskHasCompleted.Should().BeFalse();
+ _taskHasCompleted.ShouldBeFalse();
}
[Theory, AutoData]
@@ -94,7 +94,7 @@ public sealed class MessageProcessorTests : IDisposable
await processTask;
//Assert
- _taskHasCompleted.Should().BeTrue();
+ _taskHasCompleted.ShouldBeTrue();
}
private async ValueTask ProcessMessage(IMessage<byte[]> _,
CancellationToken token)
diff --git a/tests/DotPulsar.Tests/Internal/PingPongHandlerTest.cs
b/tests/DotPulsar.Tests/Internal/PingPongHandlerTest.cs
index dc4aecc..b30b090 100644
--- a/tests/DotPulsar.Tests/Internal/PingPongHandlerTest.cs
+++ b/tests/DotPulsar.Tests/Internal/PingPongHandlerTest.cs
@@ -31,7 +31,7 @@ public class PingPongHandlerTest
var actual = await
uut.State.OnStateChangeTo(PingPongHandlerState.TimedOut);
// Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -47,7 +47,7 @@ public class PingPongHandlerTest
var actual = await
uut.State.OnStateChangeTo(PingPongHandlerState.Active);
// Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -62,6 +62,6 @@ public class PingPongHandlerTest
await uut.DisposeAsync();
// Assert
- (await actual).Should().Be(expected);
+ (await actual).ShouldBe(expected);
}
}
diff --git a/tests/DotPulsar.Tests/Internal/ProducerTests.cs
b/tests/DotPulsar.Tests/Internal/ProducerTests.cs
index c483d6e..bcb6e09 100644
--- a/tests/DotPulsar.Tests/Internal/ProducerTests.cs
+++ b/tests/DotPulsar.Tests/Internal/ProducerTests.cs
@@ -47,8 +47,8 @@ public sealed class ProducerTests : IDisposable
var message = await consumer.Receive(_cts.Token);
//Assert
- message.MessageId.Should().Be(messageId);
- message.Value().Should().Be(content);
+ message.MessageId.ShouldBe(messageId);
+ message.Value().ShouldBe(content);
}
[Fact]
@@ -76,8 +76,8 @@ public sealed class ProducerTests : IDisposable
var expected = await idTask.Task;
//Assert
- message.MessageId.Should().Be(expected);
- message.Value().Should().Be(content);
+ message.MessageId.ShouldBe(expected);
+ message.Value().ShouldBe(content);
}
[Theory]
@@ -130,8 +130,8 @@ public sealed class ProducerTests : IDisposable
var actualStateForProducer2 = await
producer2.State.OnStateChangeTo(expectedStateForProducer2, _cts.Token);
//Assert
- actualStateForProducer1.Should().Be(expectedStateForProducer1);
- actualStateForProducer2.Should().Be(expectedStateForProducer2);
+ actualStateForProducer1.ShouldBe(expectedStateForProducer1);
+ actualStateForProducer2.ShouldBe(expectedStateForProducer2);
}
[Fact]
@@ -174,7 +174,7 @@ public sealed class ProducerTests : IDisposable
for (var msgIndex = 0; msgIndex < msgCount; ++msgIndex)
{
var message = await consumer.Receive(_cts.Token);
- message.Value().Should().Be($"{content}-{i}-{msgIndex}");
+ message.Value().ShouldBe($"{content}-{i}-{msgIndex}");
}
}
}
@@ -202,7 +202,7 @@ public sealed class ProducerTests : IDisposable
//Assert
for (var i = 0; i < partitions; ++i)
{
- (await
consumers[i].Receive(_cts.Token)).Value().Should().Be($"{content}-{i}");
+ (await
consumers[i].Receive(_cts.Token)).Value().ShouldBe($"{content}-{i}");
}
}
@@ -234,7 +234,7 @@ public sealed class ProducerTests : IDisposable
foundNonNegativeOne = true;
}
- foundNonNegativeOne.Should().Be(false);
+ foundNonNegativeOne.ShouldBeFalse();
}
[Fact]
@@ -265,7 +265,7 @@ public sealed class ProducerTests : IDisposable
foundNonNegativeOne = true;
}
- foundNonNegativeOne.Should().Be(true);
+ foundNonNegativeOne.ShouldBeTrue();
}
[Fact]
@@ -289,7 +289,7 @@ public sealed class ProducerTests : IDisposable
var exception = await Record.ExceptionAsync(sendTask.AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -304,7 +304,7 @@ public sealed class ProducerTests : IDisposable
var exception = await
Record.ExceptionAsync(producer.DisposeAsync().AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -321,7 +321,7 @@ public sealed class ProducerTests : IDisposable
var exception = await Record.ExceptionAsync(producer.Send("test",
_cts.Token).AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -338,7 +338,7 @@ public sealed class ProducerTests : IDisposable
var exception = await
Record.ExceptionAsync(producer.DisposeAsync().AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -358,7 +358,7 @@ public sealed class ProducerTests : IDisposable
var exception = await Record.ExceptionAsync(producer.Send("test",
_cts.Token).AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
private static async Task<IEnumerable<MessageId>>
ProduceMessages(IProducer<string> producer, int numberOfMessages,
CancellationToken ct)
diff --git a/tests/DotPulsar.Tests/Internal/ReaderTests.cs
b/tests/DotPulsar.Tests/Internal/ReaderTests.cs
index 7e1e3b6..2631cfd 100644
--- a/tests/DotPulsar.Tests/Internal/ReaderTests.cs
+++ b/tests/DotPulsar.Tests/Internal/ReaderTests.cs
@@ -45,7 +45,7 @@ public sealed class ReaderTests : IDisposable
var actual = await reader.GetLastMessageIds(_cts.Token);
//Assert
- actual.Should().BeEquivalentTo(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -72,7 +72,7 @@ public sealed class ReaderTests : IDisposable
var actual = await reader.GetLastMessageIds(_cts.Token);
//Assert
- actual.Should().BeEquivalentTo(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -101,7 +101,7 @@ public sealed class ReaderTests : IDisposable
var actual = await reader.GetLastMessageIds(_cts.Token);
//Assert
- actual.Should().BeEquivalentTo(expected);
+ actual.ShouldBeEquivalentTo(expected);
}
[Fact]
@@ -131,7 +131,7 @@ public sealed class ReaderTests : IDisposable
}
//Assert
- actual.Should().BeEquivalentTo(expected);
+ actual.ShouldBeEquivalentTo(expected);
}
[Fact]
@@ -162,7 +162,7 @@ public sealed class ReaderTests : IDisposable
}
//Assert
- actual.Should().BeEquivalentTo(expected);
+ actual.ShouldBe(expected, true);
}
[Fact]
@@ -187,7 +187,7 @@ public sealed class ReaderTests : IDisposable
var exception = await Record.ExceptionAsync(() => receiveTask);
//Assert
- exception.Should().BeOfType<ReaderFaultedException>();
+ exception.ShouldBeOfType<ReaderFaultedException>();
}
[Fact]
@@ -209,7 +209,7 @@ public sealed class ReaderTests : IDisposable
var exception = await
Record.ExceptionAsync(reader.Receive(_cts.Token).AsTask);
//Assert
- exception.Should().BeOfType<ReaderFaultedException>();
+ exception.ShouldBeOfType<ReaderFaultedException>();
}
[Fact]
@@ -233,7 +233,7 @@ public sealed class ReaderTests : IDisposable
var exception = await Record.ExceptionAsync(receiveTask.AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -253,7 +253,7 @@ public sealed class ReaderTests : IDisposable
var exception = await
Record.ExceptionAsync(reader.Receive(_cts.Token).AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -268,7 +268,7 @@ public sealed class ReaderTests : IDisposable
var exception = await
Record.ExceptionAsync(reader.DisposeAsync().AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -285,7 +285,7 @@ public sealed class ReaderTests : IDisposable
var exception = await
Record.ExceptionAsync(reader.DisposeAsync().AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
[Fact]
@@ -308,7 +308,7 @@ public sealed class ReaderTests : IDisposable
var exception = await
Record.ExceptionAsync(reader.Receive(_cts.Token).AsTask);
//Assert
- exception.Should().BeNull();
+ exception.ShouldBeNull();
}
private IProducer<string> CreateProducer(IPulsarClient pulsarClient,
string topicName)
diff --git a/tests/DotPulsar.Tests/Internal/RoundRobinPartitionRouterTests.cs
b/tests/DotPulsar.Tests/Internal/RoundRobinPartitionRouterTests.cs
index 81181b4..f3928ee 100644
--- a/tests/DotPulsar.Tests/Internal/RoundRobinPartitionRouterTests.cs
+++ b/tests/DotPulsar.Tests/Internal/RoundRobinPartitionRouterTests.cs
@@ -17,7 +17,7 @@ public class RoundRobinPartitionRouterTests
var result = router.ChoosePartition(messageMetadata, 4);
//Assert
- result.Should().BeInRange(0, 3);
+ result.ShouldBeInRange(0, 3);
}
[Theory]
@@ -33,6 +33,6 @@ public class RoundRobinPartitionRouterTests
var result = router.ChoosePartition(messageMetadata,
numberOfPartitions);
//Assert
- result.Should().BeInRange(0, numberOfPartitions);
+ result.ShouldBeInRange(0, numberOfPartitions);
}
}
diff --git a/tests/DotPulsar.Tests/Internal/SequenceBuilderTests.cs
b/tests/DotPulsar.Tests/Internal/SequenceBuilderTests.cs
index 15f167f..fa3b6cb 100644
--- a/tests/DotPulsar.Tests/Internal/SequenceBuilderTests.cs
+++ b/tests/DotPulsar.Tests/Internal/SequenceBuilderTests.cs
@@ -35,7 +35,7 @@ public class SequenceBuilderTests
//Assert
var expected = CreateRange(0, 10);
- actual.Should().Equal(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -56,7 +56,7 @@ public class SequenceBuilderTests
//Assert
var expected = CreateRange(0, 10);
- actual.Should().Equal(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -74,7 +74,7 @@ public class SequenceBuilderTests
//Assert
var expected = CreateRange(0, 10);
- actual.Should().Equal(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -95,7 +95,7 @@ public class SequenceBuilderTests
//Assert
var expected = CreateRange(0, 10);
- actual.Should().Equal(expected);
+ actual.ShouldBe(expected);
}
[Fact]
@@ -113,8 +113,8 @@ public class SequenceBuilderTests
//Assert
var expected = CreateRange(0, 4);
- actual1.Should().Equal(expected);
- actual2.Should().Equal(expected);
+ actual1.ShouldBe(expected);
+ actual2.ShouldBe(expected);
}
private static byte[] CreateRange(int start, int count)
@@ -122,7 +122,7 @@ public class SequenceBuilderTests
var bytes = new byte[count];
for (var i = 0; i < count; ++i)
- bytes[i] = System.Convert.ToByte(start + i);
+ bytes[i] = Convert.ToByte(start + i);
return bytes;
}
diff --git a/tests/DotPulsar.Tests/Internal/SerializerTests.cs
b/tests/DotPulsar.Tests/Internal/SerializerTests.cs
index fa49d52..974047b 100644
--- a/tests/DotPulsar.Tests/Internal/SerializerTests.cs
+++ b/tests/DotPulsar.Tests/Internal/SerializerTests.cs
@@ -30,6 +30,6 @@ public class SerializerTests
//Assert
var expected = new byte[] { 0x00, 0x01, 0x02, 0x03 };
- actual.Should().Equal(expected);
+ actual.ShouldBe(expected);
}
}
diff --git a/tests/DotPulsar.Tests/Internal/SinglePartitionRouterTests.cs
b/tests/DotPulsar.Tests/Internal/SinglePartitionRouterTests.cs
index 899b258..c37b6e8 100644
--- a/tests/DotPulsar.Tests/Internal/SinglePartitionRouterTests.cs
+++ b/tests/DotPulsar.Tests/Internal/SinglePartitionRouterTests.cs
@@ -17,7 +17,7 @@ public class SinglePartitionRouterTests
var result = router.ChoosePartition(messageMetadata, 4);
//Assert
- result.Should().BeInRange(0, 3);
+ result.ShouldBeInRange(0, 3);
}
[Theory]
@@ -33,6 +33,6 @@ public class SinglePartitionRouterTests
var result = router.ChoosePartition(messageMetadata,
numberOfPartitions);
//Assert
- result.Should().BeInRange(0, numberOfPartitions);
+ result.ShouldBeInRange(0, numberOfPartitions);
}
}
diff --git a/tests/DotPulsar.Tests/Internal/StateManagerTests.cs
b/tests/DotPulsar.Tests/Internal/StateManagerTests.cs
index a294066..367942b 100644
--- a/tests/DotPulsar.Tests/Internal/StateManagerTests.cs
+++ b/tests/DotPulsar.Tests/Internal/StateManagerTests.cs
@@ -38,7 +38,7 @@ public class StateManagerTests
var actual = uut.SetState(newState);
//Assert
- actual.Should().Be(expected);
+ actual.ShouldBe(expected);
}
[Theory]
@@ -54,7 +54,7 @@ public class StateManagerTests
_ = uut.SetState(newState);
//Assert
- uut.CurrentState.Should().Be(ProducerState.Closed);
+ uut.CurrentState.ShouldBe(ProducerState.Closed);
}
[Theory]
@@ -72,7 +72,7 @@ public class StateManagerTests
_ = uut.SetState(newState);
//Assert
- task.IsCompleted.Should().BeTrue();
+ task.IsCompleted.ShouldBeTrue();
}
[Theory]
@@ -90,7 +90,7 @@ public class StateManagerTests
_ = uut.SetState(newState);
//Assert
- task.IsCompleted.Should().BeTrue();
+ task.IsCompleted.ShouldBeTrue();
}
[Theory]
@@ -123,7 +123,7 @@ public class StateManagerTests
var task = uut.OnStateChangeTo(wantedState, default);
//Assert
- task.IsCompleted.Should().BeFalse();
+ task.IsCompleted.ShouldBeFalse();
}
[Theory]
@@ -138,7 +138,7 @@ public class StateManagerTests
var task = uut.OnStateChangeTo(state, default);
//Assert
- task.IsCompleted.Should().BeTrue();
+ task.IsCompleted.ShouldBeTrue();
}
[Theory]
@@ -153,7 +153,7 @@ public class StateManagerTests
var task = uut.OnStateChangeFrom(state, default);
//Assert
- task.IsCompleted.Should().BeFalse();
+ task.IsCompleted.ShouldBeFalse();
}
[Theory]
@@ -170,7 +170,7 @@ public class StateManagerTests
var task = uut.OnStateChangeFrom(fromState, default);
//Assert
- task.IsCompleted.Should().BeTrue();
+ task.IsCompleted.ShouldBeTrue();
}
[Theory]
@@ -186,7 +186,7 @@ public class StateManagerTests
var task = uut.OnStateChangeFrom(state, default);
//Assert
- task.IsCompleted.Should().BeTrue();
+ task.IsCompleted.ShouldBeTrue();
}
[Theory]
@@ -202,7 +202,7 @@ public class StateManagerTests
_ = uut.SetState(ProducerState.Closed);
//Assert
- task.IsCompleted.Should().BeTrue();
+ task.IsCompleted.ShouldBeTrue();
}
[Theory]
@@ -218,7 +218,7 @@ public class StateManagerTests
_ = uut.SetState(newState);
//Assert
- task.IsCompleted.Should().BeFalse();
+ task.IsCompleted.ShouldBeFalse();
}
[Fact]
@@ -234,7 +234,7 @@ public class StateManagerTests
var exception = await Record.ExceptionAsync(() => task.AsTask()); //
xUnit can't record ValueTask yet
//Assert
- exception.Should().BeOfType<TaskCanceledException>();
+ exception.ShouldBeOfType<TaskCanceledException>();
}
[Fact]
@@ -250,6 +250,6 @@ public class StateManagerTests
var exception = await Record.ExceptionAsync(() => task.AsTask()); //
xUnit can't record ValueTask yet
//Assert
- exception.Should().BeOfType<TaskCanceledException>();
+ exception.ShouldBeOfType<TaskCanceledException>();
}
}
diff --git a/tests/DotPulsar.Tests/MessageIdTests.cs
b/tests/DotPulsar.Tests/MessageIdTests.cs
index d28eaac..abce4a5 100644
--- a/tests/DotPulsar.Tests/MessageIdTests.cs
+++ b/tests/DotPulsar.Tests/MessageIdTests.cs
@@ -25,11 +25,11 @@ public class MessageIdTests
var m1 = new MessageId(1, 2, 3, 4);
var m2 = new MessageId(1, 2, 3, 4);
- m1.CompareTo(m2).Should().Be(0);
- (m1 < m2).Should().BeFalse();
- (m1 > m2).Should().BeFalse();
- (m1 >= m2).Should().BeTrue();
- (m1 <= m2).Should().BeTrue();
+ m1.CompareTo(m2).ShouldBe(0);
+ (m1 < m2).ShouldBeFalse();
+ (m1 > m2).ShouldBeFalse();
+ (m1 >= m2).ShouldBeTrue();
+ (m1 <= m2).ShouldBeTrue();
}
[Fact]
@@ -38,11 +38,11 @@ public class MessageIdTests
var m1 = new MessageId(1, 2, 3, 4,
"persistent://public/default/my-topic-partition-0");
var m2 = new MessageId(1, 2, 3, 4,
"persistent://public/default/my-topic-partition-0");
- m1.CompareTo(m2).Should().Be(0);
- (m1 < m2).Should().BeFalse();
- (m1 > m2).Should().BeFalse();
- (m1 >= m2).Should().BeTrue();
- (m1 <= m2).Should().BeTrue();
+ m1.CompareTo(m2).ShouldBe(0);
+ (m1 < m2).ShouldBeFalse();
+ (m1 > m2).ShouldBeFalse();
+ (m1 >= m2).ShouldBeTrue();
+ (m1 <= m2).ShouldBeTrue();
}
[Fact]
@@ -51,10 +51,10 @@ public class MessageIdTests
MessageId m1 = null;
MessageId m2 = null;
- (m1 < m2).Should().BeFalse();
- (m1 > m2).Should().BeFalse();
- (m1 <= m2).Should().BeTrue();
- (m1 >= m2).Should().BeTrue();
+ (m1 < m2).ShouldBeFalse();
+ (m1 > m2).ShouldBeFalse();
+ (m1 <= m2).ShouldBeTrue();
+ (m1 >= m2).ShouldBeTrue();
}
[Fact]
@@ -63,16 +63,16 @@ public class MessageIdTests
var m1 = new MessageId(1, 2, 3, 4);
MessageId m2 = null;
- m1.CompareTo(m2).Should().BePositive();
- (m1 < m2).Should().BeFalse();
- (m1 > m2).Should().BeTrue();
- (m1 <= m2).Should().BeFalse();
- (m1 >= m2).Should().BeTrue();
+ m1.CompareTo(m2).ShouldBePositive();
+ (m1 < m2).ShouldBeFalse();
+ (m1 > m2).ShouldBeTrue();
+ (m1 <= m2).ShouldBeFalse();
+ (m1 >= m2).ShouldBeTrue();
- (m2 < m1).Should().BeTrue();
- (m2 > m1).Should().BeFalse();
- (m2 <= m1).Should().BeTrue();
- (m2 >= m1).Should().BeFalse();
+ (m2 < m1).ShouldBeTrue();
+ (m2 > m1).ShouldBeFalse();
+ (m2 <= m1).ShouldBeTrue();
+ (m2 >= m1).ShouldBeFalse();
}
[Theory]
@@ -85,9 +85,9 @@ public class MessageIdTests
var m1 = new MessageId(ledgerId, entryId, partition, batchIndex);
var m2 = new MessageId(1, 2, 3, 4);
- m1.CompareTo(m2).Should().BePositive();
- (m1 > m2).Should().BeTrue();
- (m1 < m2).Should().BeFalse();
+ m1.CompareTo(m2).ShouldBePositive();
+ (m1 > m2).ShouldBeTrue();
+ (m1 < m2).ShouldBeFalse();
}
[Theory]
@@ -100,9 +100,9 @@ public class MessageIdTests
var m1 = new MessageId(ledgerId, entryId, partition, batchIndex);
var m2 = new MessageId(1, 2, 3, 4);
- m1.CompareTo(m2).Should().BeNegative();
- (m1 < m2).Should().BeTrue();
- (m1 > m2).Should().BeFalse();
+ m1.CompareTo(m2).ShouldBeNegative();
+ (m1 < m2).ShouldBeTrue();
+ (m1 > m2).ShouldBeFalse();
}
[Fact]
@@ -111,9 +111,9 @@ public class MessageIdTests
var m1 = new MessageId(1, 2, 3, 4);
var m2 = m1;
- m1.Equals(m2).Should().BeTrue();
- (m1 == m2).Should().BeTrue();
- (m1 != m2).Should().BeFalse();
+ m1.Equals(m2).ShouldBeTrue();
+ (m1 == m2).ShouldBeTrue();
+ (m1 != m2).ShouldBeFalse();
}
[Fact]
@@ -122,9 +122,9 @@ public class MessageIdTests
var m1 = new MessageId(1, 2, 3, 4);
var m2 = new MessageId(1, 2, 3, 4);
- m1.Equals(m2).Should().BeTrue();
- (m1 == m2).Should().BeTrue();
- (m1 != m2).Should().BeFalse();
+ m1.Equals(m2).ShouldBeTrue();
+ (m1 == m2).ShouldBeTrue();
+ (m1 != m2).ShouldBeFalse();
}
[Fact]
@@ -133,9 +133,9 @@ public class MessageIdTests
var m1 = new MessageId(1, 2, 3, 4,
"persistent://public/default/my-topic-partition-0");
var m2 = new MessageId(1, 2, 3, 4,
"persistent://public/default/my-topic-partition-0");
- m1.Equals(m2).Should().BeTrue();
- (m1 == m2).Should().BeTrue();
- (m1 != m2).Should().BeFalse();
+ m1.Equals(m2).ShouldBeTrue();
+ (m1 == m2).ShouldBeTrue();
+ (m1 != m2).ShouldBeFalse();
}
[Theory]
@@ -148,9 +148,9 @@ public class MessageIdTests
var m1 = new MessageId(ledgerId, entryId, partition, batchIndex);
var m2 = new MessageId(1, 2, 3, 4);
- m1.Equals(m2).Should().BeFalse();
- (m1 == m2).Should().BeFalse();
- (m1 != m2).Should().BeTrue();
+ m1.Equals(m2).ShouldBeFalse();
+ (m1 == m2).ShouldBeFalse();
+ (m1 != m2).ShouldBeTrue();
}
[Theory]
@@ -164,9 +164,9 @@ public class MessageIdTests
var m1 = new MessageId(ledgerId, entryId, partition, batchIndex,
topic);
var m2 = new MessageId(1, 2, 3, 4,
"persistent://public/default/my-topic-partition-1");
- m1.Equals(m2).Should().BeFalse();
- (m1 == m2).Should().BeFalse();
- (m1 != m2).Should().BeTrue();
+ m1.Equals(m2).ShouldBeFalse();
+ (m1 == m2).ShouldBeFalse();
+ (m1 != m2).ShouldBeTrue();
}
[Fact]
@@ -175,9 +175,9 @@ public class MessageIdTests
MessageId m1 = null;
MessageId m2 = null;
- (m1 == m2).Should().BeTrue();
- (m1 is null).Should().BeTrue();
- (m1 != m2).Should().BeFalse();
+ (m1 == m2).ShouldBeTrue();
+ (m1 is null).ShouldBeTrue();
+ (m1 != m2).ShouldBeFalse();
}
[Fact]
@@ -186,10 +186,10 @@ public class MessageIdTests
var m1 = new MessageId(1, 2, 3, 4);
MessageId m2 = null;
- (m1 is null).Should().BeFalse();
- (m1 == m2).Should().BeFalse();
- m1.Equals(m2).Should().BeFalse();
- (m1 != m2).Should().BeTrue();
+ (m1 is null).ShouldBeFalse();
+ (m1 == m2).ShouldBeFalse();
+ m1.Equals(m2).ShouldBeFalse();
+ (m1 != m2).ShouldBeTrue();
}
[Theory]
@@ -212,8 +212,8 @@ public class MessageIdTests
var result = MessageId.TryParse(input, out var actual);
// Assert
- result.Should().BeFalse();
- actual.Should().Be(expected);
+ result.ShouldBeFalse();
+ actual.ShouldBe(expected);
}
[Fact]
@@ -226,8 +226,8 @@ public class MessageIdTests
var result = MessageId.TryParse(expected.ToString(), out var actual);
// Assert
- result.Should().BeTrue();
- actual.Should().Be(expected);
+ result.ShouldBeTrue();
+ actual.ShouldBe(expected);
}
}
diff --git a/tests/DotPulsar.Tests/PulsarClientTests.cs
b/tests/DotPulsar.Tests/PulsarClientTests.cs
index 3e74ff7..d76fb86 100644
--- a/tests/DotPulsar.Tests/PulsarClientTests.cs
+++ b/tests/DotPulsar.Tests/PulsarClientTests.cs
@@ -45,8 +45,8 @@ public sealed class PulsarClientTests : IDisposable
var state = await
producer.State.OnStateChangeTo(ProducerState.Faulted, _cts.Token);
// Assert
- exception.Should().BeOfType<ProducerFaultedException>();
- state.Should().Be(ProducerState.Faulted);
+ exception.ShouldBeOfType<ProducerFaultedException>();
+ state.ShouldBe(ProducerState.Faulted);
}
[Fact]
@@ -71,7 +71,7 @@ public sealed class PulsarClientTests : IDisposable
var state = await
producer.State.OnStateChangeTo(ProducerState.Faulted, _cts.Token);
// Assert
- state.Should().Be(ProducerState.Faulted);
+ state.ShouldBe(ProducerState.Faulted);
}
[Fact]
@@ -91,9 +91,9 @@ public sealed class PulsarClientTests : IDisposable
var state = await
producer.State.OnStateChangeTo(ProducerState.Faulted, _cts.Token);
// Assert
- exception.Should().BeOfType<ProducerFaultedException>();
- exception.InnerException.Should().BeOfType<AuthenticationException>();
- state.Should().Be(ProducerState.Faulted);
+ exception.ShouldBeOfType<ProducerFaultedException>();
+ exception.InnerException.ShouldBeOfType<AuthenticationException>();
+ state.ShouldBe(ProducerState.Faulted);
}
[Fact]
@@ -122,7 +122,7 @@ public sealed class PulsarClientTests : IDisposable
var state = await
producer.State.OnStateChangeTo(ProducerState.Connected, _cts.Token);
// Assert
- state.Should().Be(ProducerState.Connected);
+ state.ShouldBe(ProducerState.Connected);
}
private IPulsarClient CreateClient(Func<CancellationToken,
ValueTask<string>> tokenSupplier)
