#636 - JetStream Batch Get Client support

* Changed tests, set SkipIfNatsServer * Applied dotnet format
nats-io · Nov 23, 2024 · 8e31dda · 8e31dda
1 parent 4110d1d
commit 8e31dda
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/src/NATS.Client.JetStream/Models/StreamMsgBatchGetRequest.cs b/src/NATS.Client.JetStream/Models/StreamMsgBatchGetRequest.cs
@@ -1,4 +1,4 @@
-using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations;
 using System.Text.Json.Serialization;
 
 namespace NATS.Client.JetStream.Models;

diff --git a/tests/NATS.Client.JetStream.Tests/DirectGetTest.cs b/tests/NATS.Client.JetStream.Tests/DirectGetTest.cs
@@ -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();
@@ -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?>();
@@ -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?>();
@@ -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?>();