Skip to content

Commit

Permalink
nats-io#636 - JetStream Batch Get Client support
Browse files Browse the repository at this point in the history
* Changed tests, set SkipIfNatsServer
* Applied dotnet format
  • Loading branch information
Ivandemidov00 committed Nov 23, 2024
1 parent 4110d1d commit 8e31dda
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations;
using System.Text.Json.Serialization;

namespace NATS.Client.JetStream.Models;
Expand Down
10 changes: 5 additions & 5 deletions tests/NATS.Client.JetStream.Tests/DirectGetTest.cs
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
using NATS.Client.Core.Tests;
using NATS.Client.Core.Tests;
using NATS.Client.JetStream.Models;

namespace NATS.Client.JetStream.Tests;

public class DirectGetTest
{
[Fact]
[SkipIfNatsServer(versionEarlierThan: "2.11")]
public async Task Direct_get_when_stream_disable()
{
await using var server = NatsServer.StartJS();
Expand All @@ -29,7 +29,7 @@ async Task GetBatchAction()
await Assert.ThrowsAsync<InvalidOperationException>(GetBatchAction);
}

[Fact]
[SkipIfNatsServer(versionEarlierThan: "2.11")]
public async Task Direct_get_when_stream_enable()
{
var testDataList = new List<TestData?>();
Expand Down Expand Up @@ -57,7 +57,7 @@ public async Task Direct_get_when_stream_enable()
Assert.Single(testDataList);
}

[Fact]
[SkipIfNatsServer(versionEarlierThan: "2.11")]
public async Task Direct_get_with_eobCode()
{
var testDataList = new List<TestData?>();
Expand Down Expand Up @@ -85,7 +85,7 @@ public async Task Direct_get_with_eobCode()
Assert.Equal(2, testDataList.Count);
}

[Fact]
[SkipIfNatsServer(versionEarlierThan: "2.11")]
public async Task Direct_get_min_sequence()
{
var testDataList = new List<TestData?>();
Expand Down

0 comments on commit 8e31dda

Please sign in to comment.