improve tryQueryOffset

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

RabbitMQ.Stream.Client/StreamSystem.cs

@@ -494,13 +494,12 @@ public async Task<ulong> QueryOffset(string reference, string stream)
         /// Note: TryQueryOffset could return null even if the offset exists but for any other exception.
         /// For a more precise exception handling, use QueryOffset.
         /// </summary>
-
         public async Task<ulong?> TryQueryOffset(string reference, string stream)
         {
             try
             {
-                var qOffset = await QueryOffset(reference, stream).ConfigureAwait(false);
-                return qOffset;
+                var response = await _client.QueryOffset(reference, stream).ConfigureAwait(false);
+                return response.Offset;
             }
             catch (Exception)
             {

Tests/RawConsumerSystemTests.cs

@@ -527,6 +527,7 @@ await Assert.ThrowsAsync<OffsetNotFoundException>(() =>
                 system.QueryOffset("reference_does_not_exist", stream));
 
             Assert.Null(await system.TryQueryOffset("reference_does_not_exist", stream));
+            Assert.Null(await system.TryQueryOffset(Reference, "stream_does_not_exist"));
 
             await rawConsumer.Close();
             await system.DeleteStream(stream);
@@ -584,8 +585,10 @@ public async Task ShouldConsumeFromStoredOffset()
 
             // new consumer that should start from stored offset
             var offset = await system.QueryOffset(Reference, stream);
+            var tryOffset = await system.TryQueryOffset(Reference, stream);
             // the offset received must be the same from the last stored
             Assert.Equal(offset, await storedOffset.Task);
+            Assert.Equal(offset, tryOffset);
             var messagesConsumed = new TaskCompletionSource<ulong>();
             var rawConsumerWithOffset = await system.CreateRawConsumer(
                 new RawConsumerConfig(stream)