Skip to content

Commit edb6b4f

Browse files
committed
nats-io#636 - JetStream Batch Get Client support
* Code style
1 parent 84e64f9 commit edb6b4f

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

src/NATS.Client.JetStream/NatsJSStream.cs

+6-6
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,12 @@ public IAsyncEnumerable<NatsMsg<T>> GetBatchDirectAsync<T>(string nextBySubject,
196196
return GetBatchDirectInternalAsync<T>(request, serializer, cancellationToken);
197197
}
198198

199+
public ValueTask<StreamMsgGetResponse> GetAsync(StreamMsgGetRequest request, CancellationToken cancellationToken = default) =>
200+
_context.JSRequestResponseAsync<StreamMsgGetRequest, StreamMsgGetResponse>(
201+
subject: $"{_context.Opts.Prefix}.STREAM.MSG.GET.{_name}",
202+
request: request,
203+
cancellationToken);
204+
199205
private IAsyncEnumerable<NatsMsg<T>> GetBatchDirectInternalAsync<T>(StreamMsgBatchGetRequest request, INatsDeserialize<T>? serializer = default, CancellationToken cancellationToken = default)
200206
{
201207
ValidateStream();
@@ -209,12 +215,6 @@ private IAsyncEnumerable<NatsMsg<T>> GetBatchDirectInternalAsync<T>(StreamMsgBat
209215
cancellationToken: cancellationToken);
210216
}
211217

212-
public ValueTask<StreamMsgGetResponse> GetAsync(StreamMsgGetRequest request, CancellationToken cancellationToken = default) =>
213-
_context.JSRequestResponseAsync<StreamMsgGetRequest, StreamMsgGetResponse>(
214-
subject: $"{_context.Opts.Prefix}.STREAM.MSG.GET.{_name}",
215-
request: request,
216-
cancellationToken);
217-
218218
private void ThrowIfDeleted()
219219
{
220220
if (_deleted)

0 commit comments

Comments
 (0)