feat: 增加 ReceivedCallBack 回调方法

Author: ArgoZhang

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

@@ -16,8 +16,11 @@ public abstract class DataPackageHandlerBase : IDataPackageHandler
     private Memory<byte> _lastReceiveBuffer = Memory<byte>.Empty;
 
     /// <summary>
-    /// 当接收数据处理完成后，回调该函数执行接收
+    /// Gets or sets the callback function to handle received data.
     /// </summary>
+    /// <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>
     public Func<ReadOnlyMemory<byte>, ValueTask>? ReceivedCallBack { get; set; }
 
     /// <summary>

src/BootstrapBlazor/Services/TcpSocket/DefaultTcpSocketClient.cs

@@ -28,6 +28,8 @@ class DefaultTcpSocketClient : ITcpSocketClient
 
     public int ReceiveBufferSize { get; set; } = 1024 * 10;
 
+    public Func<ReadOnlyMemory<byte>, ValueTask>? ReceivedCallBack { get; set; }
+
     public DefaultTcpSocketClient(string host, int port = 0)
     {
         LocalEndPoint = new IPEndPoint(GetIPAddress(host), port);
@@ -136,6 +138,11 @@ private async ValueTask ReceiveAsync()
                 {
                     buffer = buffer[..len];
 
+                    if (ReceivedCallBack != null)
+                    {
+                        await ReceivedCallBack(buffer);
+                    }
+
                     if (_dataPackageHandler != null)
                     {
                         await _dataPackageHandler.ReceiveAsync(buffer);

src/BootstrapBlazor/Services/TcpSocket/ITcpSocketClient.cs

@@ -30,6 +30,14 @@ public interface ITcpSocketClient : IDisposable
     /// specific local endpoint, this property may return <see langword="null"/>.</remarks>
     IPEndPoint LocalEndPoint { get; }
 
+    /// <summary>
+    /// Gets or sets the callback function to handle received data.
+    /// </summary>
+    /// <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; }
+
     /// <summary>
     /// Configures the data handler to process incoming data packages.
     /// </summary>