refactor: 更改接口方法名称

Author: ArgoZhang

src/BootstrapBlazor.Server/Components/Samples/Sockets/Adapters.razor.cs

@@ -93,7 +93,7 @@ private async ValueTask OnReceivedAsync(ReadOnlyMemory<byte> data)
         if (_useDataAdapter)
         {
             // 使用数据适配器处理接收的数据
-            await _dataAdapter.ReceiveAsync(data, _receiveTokenSource.Token);
+            await _dataAdapter.HandlerAsync(data, _receiveTokenSource.Token);
         }
         else
         {

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

@@ -30,7 +30,7 @@ public class DataPackageAdapter : IDataPackageAdapter
     /// <param name="data"></param>
     /// <param name="token"></param>
     /// <returns></returns>
-    public virtual async ValueTask ReceiveAsync(ReadOnlyMemory<byte> data, CancellationToken token = default)
+    public virtual async ValueTask HandlerAsync(ReadOnlyMemory<byte> data, CancellationToken token = default)
     {
         if (DataPackageHandler != null)
         {
@@ -40,7 +40,7 @@ public virtual async ValueTask ReceiveAsync(ReadOnlyMemory<byte> data, Cancellat
             }
 
             // 如果存在数据处理器则调用其处理方法
-            await DataPackageHandler.ReceiveAsync(data, token);
+            await DataPackageHandler.HandlerAsync(data, token);
         }
     }
 

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

@@ -26,7 +26,7 @@ public abstract class DataPackageHandlerBase : IDataPackageHandler
     /// <param name="data"></param>
     /// <param name="token"></param>
     /// <returns></returns>
-    public abstract ValueTask ReceiveAsync(ReadOnlyMemory<byte> data, CancellationToken token = default);
+    public abstract ValueTask HandlerAsync(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/DelimiterDataPackageHandler.cs

@@ -52,7 +52,7 @@ public DelimiterDataPackageHandler(byte[] delimiter)
     /// <param name="data"></param>
     /// <param name="token"></param>
     /// <returns></returns>
-    public override async ValueTask ReceiveAsync(ReadOnlyMemory<byte> data, CancellationToken token = default)
+    public override async ValueTask HandlerAsync(ReadOnlyMemory<byte> data, CancellationToken token = default)
     {
         data = ConcatBuffer(data);
 

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

@@ -24,7 +24,7 @@ public class FixLengthDataPackageHandler(int length) : DataPackageHandlerBase
     /// <param name="data"></param>
     /// <param name="token"></param>
     /// <returns></returns>
-    public override async ValueTask ReceiveAsync(ReadOnlyMemory<byte> data, CancellationToken token = default)
+    public override async ValueTask HandlerAsync(ReadOnlyMemory<byte> data, CancellationToken token = default)
     {
         while (data.Length > 0)
         {

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

@@ -38,5 +38,5 @@ public interface IDataPackageAdapter
     /// not provided.</param>
     /// <returns>A <see cref="ValueTask"/> representing the asynchronous operation. The task completes when the data has been
     /// successfully received and processed.</returns>
-    ValueTask ReceiveAsync(ReadOnlyMemory<byte> data, CancellationToken token = default);
+    ValueTask HandlerAsync(ReadOnlyMemory<byte> data, CancellationToken token = default);
 }

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

@@ -29,5 +29,5 @@ public interface IDataPackageHandler
     /// provided.</param>
     /// <returns>A <see cref="ValueTask{TResult}"/> containing <see langword="true"/> if the data was successfully received and
     /// processed; otherwise, <see langword="false"/>.</returns>
-    ValueTask ReceiveAsync(ReadOnlyMemory<byte> data, CancellationToken token = default);
+    ValueTask HandlerAsync(ReadOnlyMemory<byte> data, CancellationToken token = default);
 }

test/UnitTest/Services/TcpSocketFactoryTest.cs

@@ -322,7 +322,7 @@ public async Task FixLengthDataPackageHandler_Ok()
         client.ReceivedCallBack = async buffer =>
         {
             // 将接收到的数据传递给 DataPackageAdapter
-            await adapter.ReceiveAsync(buffer);
+            await adapter.HandlerAsync(buffer);
         };
 
         // 测试 ConnectAsync 方法
@@ -372,7 +372,7 @@ public async Task FixLengthDataPackageHandler_Sticky()
         client.ReceivedCallBack = async buffer =>
         {
             // 将接收到的数据传递给 DataPackageAdapter
-            await adapter.ReceiveAsync(buffer);
+            await adapter.HandlerAsync(buffer);
         };
 
         // 发送数据
@@ -417,7 +417,7 @@ public async Task DelimiterDataPackageHandler_Ok()
         // 设置数据适配器
         var adapter = new DataPackageAdapter
         {
-            DataPackageHandler = new DelimiterDataPackageHandler(new byte[] { 13, 10 }),
+            DataPackageHandler = new DelimiterDataPackageHandler([13, 10]),
             ReceivedCallBack = buffer =>
             {
                 // buffer 即是接收到的数据
@@ -431,7 +431,7 @@ public async Task DelimiterDataPackageHandler_Ok()
         client.ReceivedCallBack = async buffer =>
         {
             // 将接收到的数据传递给 DataPackageAdapter
-            await adapter.ReceiveAsync(buffer);
+            await adapter.HandlerAsync(buffer);
         };
 
         // 连接 TCP Server
@@ -574,10 +574,8 @@ private static ITcpSocketClient CreateClient(Action<ServiceCollection>? builder
             builder.AddProvider(new MockLoggerProvider());
         });
         sc.AddBootstrapBlazorTcpSocketFactory();
-        if (builder != null)
-        {
-            builder(sc);
-        }
+        builder?.Invoke(sc);
+
         var provider = sc.BuildServiceProvider();
         var factory = provider.GetRequiredService<ITcpSocketFactory>();
         var client = factory.GetOrCreate("test", op => op.LocalEndPoint = Utility.ConvertToIpEndPoint("localhost", 0));
@@ -619,7 +617,7 @@ class MockSendErrorSocketProvider : ISocketClientProvider
     {
         public bool IsConnected { get; private set; }
 
-        public IPEndPoint LocalEndPoint { get; set; }
+        public IPEndPoint LocalEndPoint { get; set; } = new IPEndPoint(IPAddress.Any, 0);
 
         public ValueTask CloseAsync()
         {
@@ -647,7 +645,7 @@ class MockSendTimeoutSocketProvider : ISocketClientProvider
     {
         public bool IsConnected { get; private set; }
 
-        public IPEndPoint LocalEndPoint { get; set; }
+        public IPEndPoint LocalEndPoint { get; set; } = new IPEndPoint(IPAddress.Any, 0);
 
         public ValueTask CloseAsync()
         {