fix pipeline

Author: erwan-joly

src/NosCore.Networking/NosCore.Networking.csproj

@@ -12,7 +12,7 @@
 		<RepositoryUrl>https://github.com/NosCoreIO/NosCore.Networking.git</RepositoryUrl>
 		<PackageIconUrl></PackageIconUrl>
 		<PackageTags>nostale, noscore, nostale private server source, nostale emulator</PackageTags>
-		<Version>4.0.1</Version>
+		<Version>4.0.2</Version>
 		<PackageRequireLicenseAcceptance>false</PackageRequireLicenseAcceptance>
 		<Description>NosCore Networking</Description>
 		<PackageLicenseExpression>MIT</PackageLicenseExpression>

src/NosCore.Networking/PipelineFactory.cs

@@ -26,10 +26,11 @@ public class PipelineFactory : IPipelineFactory
         private readonly IEncoder _encoder;
         private readonly ISessionRefHolder _sessionRefHolder;
         private readonly IEnumerable<RequestFilter> _requestFilters;
+        private readonly byte? _delimiter;
 
         public PipelineFactory(ISocketChannel channel, IDecoder decoder,
            IEncoder encoder, INetworkClient clientSession,
-            IOptions<ServerConfiguration> configuration, ISessionRefHolder sessionRefHolder, IEnumerable<RequestFilter> requestFilters)
+            IOptions<ServerConfiguration> configuration, ISessionRefHolder sessionRefHolder, IEnumerable<RequestFilter> requestFilters, byte? delimiter)
         {
             _channel = channel;
             _decoder = decoder;
@@ -38,6 +39,7 @@ public PipelineFactory(ISocketChannel channel, IDecoder decoder,
             _configuration = configuration;
             _sessionRefHolder = sessionRefHolder;
             _requestFilters = requestFilters;
+            _delimiter = delimiter;
         }
 
         public void CreatePipeline()
@@ -50,10 +52,13 @@ public void CreatePipeline()
                 pipeline.AddLast(filter);
             }
 
-            pipeline.AddLast(new DelimiterBasedFrameDecoder(8192, new []
+            if (_delimiter != null)
             {
-                Unpooled.WrappedBuffer(new [] {(byte)65})
-            }));
+                pipeline.AddLast(new DelimiterBasedFrameDecoder(8192, new[] {
+                    Unpooled.WrappedBuffer(new[] { (byte)_delimiter })
+                }));
+            }
+
             pipeline.AddLast(_decoder);
             _clientSession.RegisterChannel(_channel);
             pipeline.AddLast(_clientSession);