Add ReconnectAsync method

src/NATS.Client.Core/INatsClient.cs

@@ -115,4 +115,12 @@ ValueTask<NatsMsg<TReply>> RequestAsync<TReply>(
         INatsDeserialize<TReply>? replySerializer = default,
         NatsSubOpts? replyOpts = default,
         CancellationToken cancellationToken = default);
+
+    /// <summary>
+    /// Force a reconnection to the NATS server.
+    /// </summary>
+    /// <remarks>
+    /// This method doesn't wait for the connection to be established.
+    /// </remarks>
+    ValueTask ReconnectAsync();
 }

src/NATS.Client.Core/NatsConnection.Reconnect.cs

@@ -0,0 +1,18 @@
+using Microsoft.Extensions.Logging;
+
+namespace NATS.Client.Core;
+
+public partial class NatsConnection
+{
+    /// <inheritdoc/>
+    public async ValueTask ReconnectAsync()
+    {
+        if (ConnectionState != NatsConnectionState.Open)
+        {
+            return;
+        }
+
+        _logger.LogInformation(NatsLogEvents.Connection, "Forcing reconnection to NATS server");
+        await _socket!.AbortConnectionAsync(CancellationToken.None).ConfigureAwait(false);
+    }
+}

src/NATS.Client.Simplified/NatsClient.cs

@@ -101,6 +101,9 @@ public ValueTask<NatsMsg<TReply>> RequestAsync<TRequest, TReply>(string subject,
     public ValueTask<NatsMsg<TReply>> RequestAsync<TReply>(string subject, INatsDeserialize<TReply>? replySerializer = default, NatsSubOpts? replyOpts = default, CancellationToken cancellationToken = default)
         => Connection.RequestAsync(subject, replySerializer, replyOpts, cancellationToken);
 
+    /// <inheritdoc />
+    public ValueTask ReconnectAsync() => Connection.ReconnectAsync();
+
     /// <inheritdoc />
     public ValueTask DisposeAsync() => Connection.DisposeAsync();
 }

tests/NATS.Client.JetStream.Tests/NatsJsContextFactoryTest.cs

@@ -159,6 +159,8 @@ public ValueTask<NatsSub<TReply>> CreateRequestSubAsync<TRequest, TReply>(string
 
         public ValueTask ConnectAsync() => throw new NotImplementedException();
 
+        public ValueTask ReconnectAsync() => throw new NotImplementedException();
+
         public ValueTask DisposeAsync() => throw new NotImplementedException();
     }
 }