test(DataPackageAdapter): add unit test (#6353)

* test: 更新发送失败单元测试

* test: 更新单元测试

* test: 修复 FixLengthDataPackageHandler 单元测试

* test: 更新粘包通讯单元测试

* test: 更新终止符数据处理器单元测试

* refactor: 移除 SendAsync 方法

* test: 精简单元测试

* test: 补充单元测试提高覆盖率

* refactor: 更改代码提高代码覆盖率

Author: ArgoZhang

src/BootstrapBlazor/Services/TcpSocket/DataPackage/DataPackageHandlerBase.cs

@@ -26,21 +26,7 @@ public abstract class DataPackageHandlerBase : IDataPackageHandler
     /// <param name="data"></param>
     /// <param name="token"></param>
     /// <returns></returns>
-    public virtual ValueTask<ReadOnlyMemory<byte>> SendAsync(ReadOnlyMemory<byte> data, CancellationToken token = default)
-    {
-        return ValueTask.FromResult(data);
-    }
-
-    /// <summary>
-    /// <inheritdoc/>
-    /// </summary>
-    /// <param name="data"></param>
-    /// <param name="token"></param>
-    /// <returns></returns>
-    public virtual ValueTask ReceiveAsync(ReadOnlyMemory<byte> data, CancellationToken token = default)
-    {
-        return ValueTask.CompletedTask;
-    }
+    public abstract ValueTask ReceiveAsync(ReadOnlyMemory<byte> data, CancellationToken token = default);
 
     /// <summary>
     /// Handles the processing of a sticky package by adjusting the provided buffer and length.

src/BootstrapBlazor/Services/TcpSocket/DataPackage/IDataPackageHandler.cs

@@ -18,18 +18,6 @@ public interface IDataPackageHandler
     /// </summary>
     Func<ReadOnlyMemory<byte>, ValueTask>? ReceivedCallBack { get; set; }
 
-    /// <summary>
-    /// Sends the specified data asynchronously to the target destination.
-    /// </summary>
-    /// <remarks>The method performs an asynchronous operation to send the provided data. The caller must
-    /// ensure  that the data is valid and non-empty. The returned memory block may contain a response or acknowledgment
-    /// depending on the implementation of the target destination.</remarks>
-    /// <param name="data">The data to be sent, represented as a block of memory.</param>
-    /// <param name="token">An optional <see cref="CancellationToken"/> to observe while waiting for the operation to complete.</param>
-    /// <returns>A task that represents the asynchronous operation. The task result contains a  <see cref="Memory{T}"/> of <see
-    /// cref="byte"/> representing the response or acknowledgment  received from the target destination.</returns>
-    ValueTask<ReadOnlyMemory<byte>> SendAsync(ReadOnlyMemory<byte> data, CancellationToken token = default);
-
     /// <summary>
     /// Asynchronously receives data and processes it.
     /// </summary>

src/BootstrapBlazor/Services/TcpSocket/DefaultSocketClientProvider.cs

@@ -50,7 +50,7 @@ public async ValueTask<bool> ConnectAsync(IPEndPoint endPoint, CancellationToken
     public async ValueTask<bool> SendAsync(ReadOnlyMemory<byte> data, CancellationToken token = default)
     {
         var ret = false;
-        if (_client is { Connected: true })
+        if (_client != null)
         {
             var stream = _client.GetStream();
             await stream.WriteAsync(data, token);

src/BootstrapBlazor/Services/TcpSocket/TcpSocketClientBase.cs

@@ -184,8 +184,9 @@ public virtual async ValueTask<Memory<byte>> ReceiveAsync(CancellationToken toke
 
     private async ValueTask AutoReceiveAsync()
     {
+        // 自动接收方法
         _receiveCancellationTokenSource ??= new();
-        while (_receiveCancellationTokenSource is { IsCancellationRequested: false })
+        while (true)
         {
             if (SocketClientProvider is not { IsConnected: true })
             {
@@ -197,6 +198,7 @@ private async ValueTask AutoReceiveAsync()
             var len = await ReceiveCoreAsync(SocketClientProvider, buffer, _receiveCancellationTokenSource.Token);
             if (len == 0)
             {
+                // 远端关闭或者 DisposeAsync 方法被调用时退出
                 break;
             }
         }