test: 更新单元测试

Author: ArgoZhang

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

@@ -28,22 +28,6 @@ public static IServiceCollection AddBootstrapBlazorTcpSocketFactory(this IServic
         // 增加 ISocketClientProvider 服务
         services.TryAddTransient<ITcpSocketClientProvider, DefaultTcpSocketClientProvider>();
 
-        // 增加转换器集合配置服务
-        services.AddSocketDataConverters();
-        return services;
-    }
-
-    /// <summary>
-    /// 增加 Socket 数据转换器集合配置项服务
-    /// </summary>
-    /// <param name="services"></param>
-    /// <returns></returns>
-    static IServiceCollection AddSocketDataConverters(this IServiceCollection services)
-    {
-        services.AddOptions();
-        services.TryAddSingleton<IOptionsChangeTokenSource<SocketDataConverterCollections>, ConfigurationChangeTokenSource<SocketDataConverterCollections>>();
-        services.TryAddSingleton<IConfigureOptions<SocketDataConverterCollections>, ConfigureOptions<SocketDataConverterCollections>>();
-
         return services;
     }
 

test/UnitTestTcpSocket/TcpSocketFactoryTest.cs

@@ -765,7 +765,23 @@ public async Task TryGetTypeConverter_Ok()
         var port = 8895;
         var server = StartTcpServer(port, MockSplitPackageAsync);
 
-        var client = CreateClient();
+        var client = CreateClient(builder =>
+        {
+            builder.Configure<SocketDataConverterCollections>(options =>
+            {
+                options.AddTypeConverter<OptionConvertEntity>();
+                options.AddPropertyConverter<OptionConvertEntity>(entity => entity.Header, new SocketDataPropertyConverterAttribute()
+                {
+                    Offset = 0,
+                    Length = 5
+                });
+                options.AddPropertyConverter<OptionConvertEntity>(entity => entity.Body, new SocketDataPropertyConverterAttribute()
+                {
+                    Offset = 5,
+                    Length = 2
+                });
+            });
+        });
         var tcs = new TaskCompletionSource();
         var receivedBuffer = new byte[128];