refactor: 精简代码逻辑

Author: ArgoZhang

src/BootstrapBlazor/Services/TcpSocket/DefaultTcpSocketClient.cs

@@ -15,7 +15,6 @@ namespace BootstrapBlazor.Components;
 sealed class DefaultTcpSocketClient(IPEndPoint localEndPoint) : TcpSocketClientBase
 {
     private TcpClient? _client;
-    private IDataPackageHandler? _dataPackageHandler;
     private CancellationTokenSource? _receiveCancellationTokenSource;
     private IPEndPoint? _remoteEndPoint;
 
@@ -24,13 +23,6 @@ sealed class DefaultTcpSocketClient(IPEndPoint localEndPoint) : TcpSocketClientB
     [NotNull]
     public ILogger<DefaultTcpSocketClient>? Logger { get; set; }
 
-    public override void SetDataHandler(IDataPackageHandler handler)
-    {
-        base.SetDataHandler(handler);
-
-        _dataPackageHandler = handler;
-    }
-
     public override async ValueTask<bool> ConnectAsync(IPEndPoint endPoint, CancellationToken token = default)
     {
         var ret = false;
@@ -99,9 +91,9 @@ public override async ValueTask<bool> SendAsync(ReadOnlyMemory<byte> data, Cance
                 sendToken = CancellationTokenSource.CreateLinkedTokenSource(token, sendTokenSource.Token).Token;
             }
 
-            if (_dataPackageHandler != null)
+            if (DataPackageHandler != null)
             {
-                data = await _dataPackageHandler.SendAsync(data, sendToken);
+                data = await DataPackageHandler.SendAsync(data, sendToken);
             }
 
             await stream.WriteAsync(data, sendToken);
@@ -192,9 +184,9 @@ private async ValueTask<int> ReceiveCoreAsync(TcpClient client, Memory<byte> buf
                     await ReceivedCallBack(buffer);
                 }
 
-                if (_dataPackageHandler != null)
+                if (DataPackageHandler != null)
                 {
-                    await _dataPackageHandler.ReceiveAsync(buffer, receiveToken);
+                    await DataPackageHandler.ReceiveAsync(buffer, receiveToken);
                 }
             }
         }

src/BootstrapBlazor/Services/TcpSocket/TcpSocketClientBase.cs

@@ -56,12 +56,17 @@ public abstract class TcpSocketClientBase : ITcpSocketClient
     /// </summary>
     public int ReceiveTimeout { get; set; }
 
+    /// <summary>
+    /// Gets or sets the handler responsible for processing data packages.
+    /// </summary>
+    public IDataPackageHandler? DataPackageHandler { get; protected set; }
+
     /// <summary>
     /// <inheritdoc/>
     /// </summary>
     public virtual void SetDataHandler(IDataPackageHandler handler)
     {
-
+        DataPackageHandler = handler;
     }
 
     /// <summary>