fix

Author: erwan-joly

src/NosCore.Networking/PipelineFactory.cs

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