refactor: 数据处理器增加数据转化器适配

Author: ArgoZhang

src/BootstrapBlazor/Extensions/ITcpSocketClientExtensions.cs

@@ -76,20 +76,18 @@ public static void SetDataPackageAdapter(this ITcpSocketClient client, IDataPack
     }
 
     /// <summary>
-    /// Configures the specified <see cref="ITcpSocketClient"/> to use a custom data package adapter and a callback
-    /// function for processing received data.
+    /// Configures the specified <see cref="ITcpSocketClient"/> to use a data package adapter and a callback function
+    /// for processing received data.
     /// </summary>
-    /// <remarks>This method sets up the <paramref name="client"/> to use the provided <paramref
-    /// name="adapter"/> for handling incoming data. The adapter processes the raw data received by the client and
-    /// attempts to convert it into an instance of <typeparamref name="TEntity"/>. If the conversion is successful, the
-    /// <paramref name="callback"/> is invoked with the converted entity; otherwise, it is invoked with <see
-    /// langword="null"/>.</remarks>
-    /// <typeparam name="TEntity">The type of the entity that the data package adapter will attempt to convert the received data into.</typeparam>
-    /// <param name="client">The <see cref="ITcpSocketClient"/> instance to configure.</param>
-    /// <param name="adapter">The <see cref="IDataPackageAdapter"/> instance responsible for handling and processing incoming data.</param>
-    /// <param name="callback">A callback function to be invoked with the processed data of type <typeparamref name="TEntity"/>.  The callback
-    /// receives <see langword="null"/> if the data cannot be converted to <typeparamref name="TEntity"/>.</param>
-    public static void SetDataPackageAdapter<TEntity>(this ITcpSocketClient client, IDataPackageAdapter adapter, Func<TEntity?, Task> callback)
+    /// <remarks>This method sets up the <paramref name="client"/> to process incoming data using the
+    /// specified <paramref name="adapter"/> and  <paramref name="socketDataConverter"/>. The <paramref
+    /// name="callback"/> is called with the converted entity whenever data is received.</remarks>
+    /// <typeparam name="TEntity">The type of the entity that the data will be converted to.</typeparam>
+    /// <param name="client">The TCP socket client to configure.</param>
+    /// <param name="adapter">The data package adapter responsible for handling incoming data.</param>
+    /// <param name="socketDataConverter">The converter used to transform the received data into the specified entity type.</param>
+    /// <param name="callback">The callback function to be invoked with the converted entity.</param>
+    public static void SetDataPackageAdapter<TEntity>(this ITcpSocketClient client, IDataPackageAdapter adapter, ISocketDataConverter<TEntity> socketDataConverter, Func<TEntity?, Task> callback)
     {
         // 设置 ITcpSocketClient 的回调函数
         client.ReceivedCallBack = async buffer =>
@@ -102,12 +100,9 @@ public static void SetDataPackageAdapter<TEntity>(this ITcpSocketClient client,
         adapter.ReceivedCallBack = async buffer =>
         {
             TEntity? ret = default;
-            if (adapter.TryConvertTo(buffer, out var t))
+            if (socketDataConverter.TryConvertTo(buffer, out var t))
             {
-                if (t is TEntity entity)
-                {
-                    ret = entity;
-                }
+                ret = t;
             }
             await callback(ret);
         };

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

@@ -48,12 +48,17 @@ public virtual async ValueTask HandlerAsync(ReadOnlyMemory<byte> data, Cancellat
     /// <inheritdoc/>
     /// </summary>
     /// <param name="data"></param>
+    /// <param name="socketDataConverter"></param>
     /// <param name="entity"></param>
     /// <returns></returns>
-    public virtual bool TryConvertTo(ReadOnlyMemory<byte> data, [NotNullWhen(true)] out object? entity)
+    public virtual bool TryConvertTo<TEntity>(ReadOnlyMemory<byte> data, ISocketDataConverter<TEntity> socketDataConverter, out TEntity? entity)
     {
-        entity = null;
-        return false;
+        entity = default;
+        if (socketDataConverter.TryConvertTo(data, out var v))
+        {
+            entity = v;
+        }
+        return entity != null;
     }
 
     /// <summary>

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

@@ -41,13 +41,15 @@ public interface IDataPackageAdapter
     ValueTask HandlerAsync(ReadOnlyMemory<byte> data, CancellationToken token = default);
 
     /// <summary>
-    /// Attempts to convert the specified binary data into an object representation.
+    /// Attempts to convert the specified byte data into an entity of type <typeparamref name="TEntity"/>.
     /// </summary>
-    /// <remarks>This method does not throw an exception if the conversion fails. Instead, it returns  <see
-    /// langword="false"/> and sets <paramref name="entity"/> to <see langword="null"/>.</remarks>
-    /// <param name="data">The binary data to be converted. Must not be empty.</param>
-    /// <param name="entity">When this method returns <see langword="true"/>, contains the converted object.  When this method returns <see
-    /// langword="false"/>, contains <see langword="null"/>.</param>
+    /// <remarks>This method does not throw an exception if the conversion fails. Instead, it returns <see
+    /// langword="false"/> and sets <paramref name="entity"/> to its default value.</remarks>
+    /// <typeparam name="TEntity">The type of the entity to convert the data to.</typeparam>
+    /// <param name="data">The byte data to be converted.</param>
+    /// <param name="socketDataConverter">The converter used to transform the byte data into an entity.</param>
+    /// <param name="entity">When this method returns, contains the converted entity if the conversion was successful; otherwise, the default
+    /// value for the type of the entity.</param>
     /// <returns><see langword="true"/> if the conversion was successful; otherwise, <see langword="false"/>.</returns>
-    bool TryConvertTo(ReadOnlyMemory<byte> data, [NotNullWhen(true)] out object? entity);
+    bool TryConvertTo<TEntity>(ReadOnlyMemory<byte> data, ISocketDataConverter<TEntity> socketDataConverter, out TEntity? entity);
 }