test: 更新单元测试

Author: ArgoZhang

src/extensions/BootstrapBlazor.Socket/DataConverter/DataConverter.cs

@@ -38,9 +38,7 @@ public virtual bool TryConvertTo(ReadOnlyMemory<byte> data, [NotNullWhen(true)]
                 ret = true;
             }
         }
-        catch (Exception e)
-        {
-        }
+        catch { }
 
         return ret;
     }

test/UnitTestTcpSocket/TcpSocketFactoryTest.cs

@@ -497,14 +497,15 @@ public async Task FixLengthDataPackageHandler_Ok()
 
         // 设置数据适配器
         var adapter = new DataPackageAdapter(new FixLengthDataPackageHandler(7));
-        client.SetDataPackageAdapter(adapter, buffer =>
+        var callback = new Func<ReadOnlyMemory<byte>, ValueTask>(buffer =>
         {
             // buffer 即是接收到的数据
             buffer.CopyTo(receivedBuffer);
             receivedBuffer = receivedBuffer[..buffer.Length];
             tcs.SetResult();
             return ValueTask.CompletedTask;
         });
+        client.AddDataPackageAdapter(adapter, callback);
 
         // 测试 ConnectAsync 方法
         var connect = await client.ConnectAsync("localhost", port);
@@ -538,7 +539,7 @@ public async Task FixLengthDataPackageHandler_Sticky()
 
         // 设置数据适配器
         var adapter = new DataPackageAdapter(new FixLengthDataPackageHandler(7));
-        client.SetDataPackageAdapter(adapter, buffer =>
+        client.AddDataPackageAdapter(adapter, buffer =>
         {
             // buffer 即是接收到的数据
             buffer.CopyTo(receivedBuffer);
@@ -588,7 +589,7 @@ public async Task DelimiterDataPackageHandler_Ok()
 
         // 设置数据适配器
         var adapter = new DataPackageAdapter(new DelimiterDataPackageHandler([13, 10]));
-        client.SetDataPackageAdapter(adapter, buffer =>
+        client.AddDataPackageAdapter(adapter, buffer =>
         {
             // buffer 即是接收到的数据
             buffer.CopyTo(receivedBuffer);
@@ -641,7 +642,7 @@ public async Task TryConvertTo_Ok()
 
         // 设置数据适配器
         var adapter = new DataPackageAdapter(new FixLengthDataPackageHandler(29));
-        client.SetDataPackageAdapter(adapter, new DataConverter<MockEntity>(), t =>
+        client.AddDataPackageAdapter(adapter, new DataConverter<MockEntity>(), t =>
         {
             entity = t;
             tcs.SetResult();
@@ -706,7 +707,7 @@ public async Task TryConvertTo_Ok()
 
         // 测试 SocketDataConverter 标签功能
         tcs = new TaskCompletionSource();
-        client.SetDataPackageAdapter<MockEntity>(adapter, t =>
+        client.AddDataPackageAdapter<MockEntity>(adapter, t =>
         {
             entity = t;
             tcs.SetResult();
@@ -728,7 +729,7 @@ public async Task TryConvertTo_Ok()
         // 测试 SetDataPackageAdapter 泛型无标签情况
         tcs = new TaskCompletionSource();
         NoConvertEntity? noConvertEntity = null;
-        client.SetDataPackageAdapter<NoConvertEntity>(adapter, t =>
+        client.AddDataPackageAdapter<NoConvertEntity>(adapter, t =>
         {
             noConvertEntity = t;
             tcs.SetResult();
@@ -779,7 +780,7 @@ public async Task TryGetTypeConverter_Ok()
         var adapter = new DataPackageAdapter(new FixLengthDataPackageHandler(7));
 
         OptionConvertEntity? entity = null;
-        client.SetDataPackageAdapter<OptionConvertEntity>(adapter, data =>
+        client.AddDataPackageAdapter<OptionConvertEntity>(adapter, data =>
         {
             // buffer 即是接收到的数据
             entity = data;
@@ -857,7 +858,7 @@ public async Task SetDataPackageAdapter_Ok()
         var connect = await client.ConnectAsync("localhost", port);
 
         client.AddDataPackageAdapter(new DataPackageAdapter(new FixLengthDataPackageHandler(7)), ReceivedCallBack);
-        client.SetDataPackageAdapter(new FixLengthDataPackageHandler(7), ReceivedCallBack);
+        client.AddDataPackageAdapter(new FixLengthDataPackageHandler(7), ReceivedCallBack);
 
         var data = new ReadOnlyMemory<byte>([1, 2, 3, 4, 5]);
         await client.SendAsync(data);
@@ -889,10 +890,10 @@ public async Task SetDataPackageAdapter_Generic()
         var connect = await client.ConnectAsync("localhost", port);
 
         client.AddDataPackageAdapter(new DataPackageAdapter(new FixLengthDataPackageHandler(7)), ReceivedCallBack);
-        client.SetDataPackageAdapter<MockEntity>(new FixLengthDataPackageHandler(7), ReceivedEntityCallBack);
+        client.AddDataPackageAdapter<MockEntity>(new FixLengthDataPackageHandler(7), ReceivedEntityCallBack);
 
         client.AddDataPackageAdapter(new DataPackageAdapter(new FixLengthDataPackageHandler(7)), ReceivedCallBack);
-        client.SetDataPackageAdapter(new FixLengthDataPackageHandler(7), new MockSocketDataConverter(), ReceivedEntityCallBack);
+        client.AddDataPackageAdapter(new FixLengthDataPackageHandler(7), new MockSocketDataConverter(), ReceivedEntityCallBack);
 
         var data = new ReadOnlyMemory<byte>([1, 2, 3, 4, 5]);
         await client.SendAsync(data);
@@ -930,7 +931,7 @@ public async Task Convert_Ok()
         // 连接 TCP Server
         var connect = await client.ConnectAsync("localhost", port);
 
-        client.SetDataPackageAdapter<MockConverterEntity>(new FixLengthDataPackageHandler(7), ReceivedCallBack);
+        client.AddDataPackageAdapter<MockConverterEntity>(new FixLengthDataPackageHandler(7), ReceivedCallBack);
 
         var data = new ReadOnlyMemory<byte>([1, 2, 3, 4, 5]);
         await client.SendAsync(data);