From 8e31dda924e18f6ce649ac5eff379163d7a52c6f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=94=D0=B5=D0=BC=D0=B8=D0=B4=D0=BE=D0=B2=20=D0=98=D0=B2?= =?UTF-8?q?=D0=B0=D0=BD?= Date: Sat, 23 Nov 2024 11:34:50 +0500 Subject: [PATCH] #636 - JetStream Batch Get Client support * Changed tests, set SkipIfNatsServer * Applied dotnet format --- .../Models/StreamMsgBatchGetRequest.cs | 2 +- tests/NATS.Client.JetStream.Tests/DirectGetTest.cs | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/src/NATS.Client.JetStream/Models/StreamMsgBatchGetRequest.cs b/src/NATS.Client.JetStream/Models/StreamMsgBatchGetRequest.cs index 7ad84a6c..400cdb4c 100644 --- 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 index 7cefb768..7d5c2860 100644 --- 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(GetBatchAction); } - [Fact] + [SkipIfNatsServer(versionEarlierThan: "2.11")] public async Task Direct_get_when_stream_enable() { var testDataList = new List(); @@ -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(); @@ -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();