Fixed naming

Author: sakno

src/DotNext.Tests/Net/Multiplexing/TcpMultiplexerTests.cs

@@ -248,7 +248,7 @@ public static async Task WaitForConnectionAsync()
         await using var server = new TcpMultiplexedListener(LocalEndPoint, new() { Timeout = DefaultTimeout });
         await server.StartAsync();
 
-        var task = client.WaitForConnectionAsync().AsTask();
+        var task = client.EnsureConnectedAsync().AsTask();
         False(task.IsCompleted);
 
         await client.StartAsync();
@@ -262,7 +262,7 @@ public static async Task WaitForDisposedConnectionAsync()
         Task task;
         await using (var client = new TcpMultiplexedClient(LocalEndPoint, new() { Timeout = DefaultTimeout }))
         {
-            task = client.WaitForConnectionAsync().AsTask();
+            task = client.EnsureConnectedAsync().AsTask();
         }
 
         await ThrowsAsync<ObjectDisposedException>(Func.Constant(task));

src/cluster/DotNext.Net.Cluster/Net/Multiplexing/MultiplexedClient.cs

@@ -46,7 +46,7 @@ protected MultiplexedClient(Options configuration)
         output = input.CreateOutput(GC.AllocateArray<byte>(configuration.BufferCapacity, pinned: true), configuration.Timeout);
     }
 
-    private Task WaitForConnectionCoreAsync(CancellationToken token)
+    private Task EnsureConnectedCoreAsync(CancellationToken token)
         => readiness?.Task.WaitAsync(token) ?? Task.CompletedTask;
 
     /// <summary>
@@ -57,7 +57,7 @@ private Task WaitForConnectionCoreAsync(CancellationToken token)
     /// <exception cref="ObjectDisposedException">The client is disposed.</exception>
     public ValueTask StartAsync(CancellationToken token = default)
     {
-        var task = WaitForConnectionCoreAsync(token);
+        var task = EnsureConnectedCoreAsync(token);
         if (ReferenceEquals(dispatcher, Task.CompletedTask))
         {
             dispatcher = DispatchAsync();
@@ -75,8 +75,8 @@ public ValueTask StartAsync(CancellationToken token = default)
     /// </remarks>
     /// <param name="token">The token that can be used to cancel the operation.</param>
     /// <returns>The task representing connection state.</returns>
-    public ValueTask WaitForConnectionAsync(CancellationToken token = default)
-        => new(WaitForConnectionCoreAsync(token));
+    public ValueTask EnsureConnectedAsync(CancellationToken token = default)
+        => new(EnsureConnectedCoreAsync(token));
 
     /// <summary>
     /// Creates a new multiplexed client stream.