Move interface out of internal

nats-io · Oct 8, 2024 · 526f09a · 526f09a
1 parent 7d2e9fb
commit 526f09a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/src/NATS.Client.Core/INatsConnection.cs b/src/NATS.Client.Core/INatsConnection.cs
@@ -1,6 +1,5 @@
 using System.Diagnostics.CodeAnalysis;
 using System.Threading.Channels;
-using NATS.Client.Core.Internal;
 
 namespace NATS.Client.Core;
 

diff --git a/...Client.Core/Internal/ISocketConnection.cs → src/NATS.Client.Core/ISocketConnection.cs b/...Client.Core/Internal/ISocketConnection.cs → src/NATS.Client.Core/ISocketConnection.cs
@@ -1,4 +1,4 @@
-namespace NATS.Client.Core.Internal;
+namespace NATS.Client.Core;
 
 public interface ISocketConnection : IAsyncDisposable
 {

diff --git a/tests/NATS.Client.JetStream.Tests/NatsJsContextFactoryTest.cs b/tests/NATS.Client.JetStream.Tests/NatsJsContextFactoryTest.cs
@@ -105,6 +105,8 @@ public class MockConnection : INatsConnection
         public INatsSubscriptionManager SubscriptionManager { get; } = new TestSubscriptionManager();
 
         public NatsHeaderParser HeaderParser { get; } = new NatsHeaderParser(Encoding.UTF8);
+        public Func<(string Host, int Port), ValueTask<(string Host, int Port)>>? OnConnectingAsync { get; set; }
+        public Func<ISocketConnection, ValueTask<ISocketConnection>>? OnSocketAvailableAsync { get; set; }
 
         public ValueTask<TimeSpan> PingAsync(CancellationToken cancellationToken = default) => throw new NotImplementedException();