refactor: 更改回调名称

Author: ArgoZhang

src/extensions/BootstrapBlazor.TcpSocket/DefaultTcpSocketClient.cs

@@ -47,7 +47,7 @@ class DefaultTcpSocketClient(TcpSocketClientOptions options) : IServiceProvider,
     /// <summary>
     /// <inheritdoc/>
     /// </summary>
-    public Func<ReadOnlyMemory<byte>, ValueTask>? ReceivedCallBack { get; set; }
+    public Func<ReadOnlyMemory<byte>, ValueTask>? ReceivedCallback { get; set; }
 
     /// <summary>
     /// <inheritdoc/>
@@ -329,10 +329,10 @@ private async ValueTask<int> ReceiveCoreAsync(ITcpSocketClientProvider client, M
                 buffer = buffer[..len];
             }
 
-            if (ReceivedCallBack != null)
+            if (ReceivedCallback != null)
             {
                 // 如果订阅回调则触发回调
-                await ReceivedCallBack(buffer);
+                await ReceivedCallback(data);
             }
         }
         catch (OperationCanceledException ex)

src/extensions/BootstrapBlazor.TcpSocket/Extensions/ITcpSocketClientExtensions.cs

@@ -76,7 +76,7 @@ async ValueTask ReceivedCallback(ReadOnlyMemory<byte> buffer)
             Cache.Add(client, [(adapter, ReceivedCallback)]);
         }
 
-        client.ReceivedCallBack += ReceivedCallback;
+        client.ReceivedCallback += ReceivedCallback;
 
         // 设置 DataPackageAdapter 的回调函数
         adapter.ReceivedCallBack = callback;
@@ -94,7 +94,7 @@ public static void RemoveDataPackageAdapter(this ITcpSocketClient client, Func<R
             var items = list.Where(i => i.Adapter.ReceivedCallBack == callback).ToList();
             foreach (var c in items)
             {
-                client.ReceivedCallBack -= c.Callback;
+                client.ReceivedCallback -= c.Callback;
                 list.Remove(c);
             }
         }
@@ -142,7 +142,7 @@ async ValueTask ReceivedCallback(ReadOnlyMemory<byte> buffer)
             EntityCache.Add(client, [(ReceivedCallback, callback)]);
         }
 
-        client.ReceivedCallBack += ReceivedCallback;
+        client.ReceivedCallback += ReceivedCallback;
 
         // 设置 DataPackageAdapter 的回调函数
         adapter.ReceivedCallBack = async buffer =>
@@ -168,7 +168,7 @@ public static void RemoveDataPackageAdapter<TEntity>(this ITcpSocketClient clien
             var items = list.Where(i => i.EntityCallback.Equals(callback)).ToList();
             foreach (var c in items)
             {
-                client.ReceivedCallBack -= c.ReceivedCallback;
+                client.ReceivedCallback -= c.ReceivedCallback;
                 list.Remove(c);
             }
         }
@@ -217,7 +217,7 @@ async ValueTask ReceivedCallback(ReadOnlyMemory<byte> buffer)
             EntityCache.Add(client, [(ReceivedCallback, callback)]);
         }
 
-        client.ReceivedCallBack += ReceivedCallback;
+        client.ReceivedCallback += ReceivedCallback;
 
         IDataConverter<TEntity>? converter = null;
 

src/extensions/BootstrapBlazor.TcpSocket/ITcpSocketClient.cs

@@ -35,7 +35,7 @@ public interface ITcpSocketClient : IAsyncDisposable
     /// <remarks>The callback function should be designed to handle the received data efficiently and
     /// asynchronously.  Ensure that the implementation does not block or perform long-running operations, as this may
     /// impact performance.</remarks>
-    Func<ReadOnlyMemory<byte>, ValueTask>? ReceivedCallBack { get; set; }
+    Func<ReadOnlyMemory<byte>, ValueTask>? ReceivedCallback { get; set; }
 
     /// <summary>
     /// Gets or sets the callback function that is invoked when a connection attempt is initiated.

test/UnitTestTcpSocket/TcpSocketFactoryTest.cs

@@ -337,7 +337,7 @@ public async Task ReceiveAsync_Error()
         var tcs = new TaskCompletionSource();
 
         // 增加接收回调方法
-        client.ReceivedCallBack = b =>
+        client.ReceivedCallback = b =>
         {
             buffer = b;
             tcs.SetResult();