Skip to content

Commit 0f55ca5

Browse files
committed
fix
1 parent 7c67726 commit 0f55ca5

3 files changed

Lines changed: 17 additions & 5 deletions

File tree

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
// __ _ __ __ ___ __ ___ ___
2+
// | \| |/__\ /' _/ / _//__\| _ \ __|
3+
// | | ' | \/ |`._`.| \_| \/ | v / _|
4+
// |_|\__|\__/ |___/ \__/\__/|_|_\___|
5+
// -----------------------------------
6+
7+
namespace NosCore.Networking;
8+
9+
public interface IRequestDelimiter
10+
{
11+
public byte? Delimiter { get; set; }
12+
}

src/NosCore.Networking/NosCore.Networking.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
<RepositoryUrl>https://github.com/NosCoreIO/NosCore.Networking.git</RepositoryUrl>
1313
<PackageIconUrl></PackageIconUrl>
1414
<PackageTags>nostale, noscore, nostale private server source, nostale emulator</PackageTags>
15-
<Version>4.0.2</Version>
15+
<Version>4.0.3</Version>
1616
<PackageRequireLicenseAcceptance>false</PackageRequireLicenseAcceptance>
1717
<Description>NosCore Networking</Description>
1818
<PackageLicenseExpression>MIT</PackageLicenseExpression>

src/NosCore.Networking/PipelineFactory.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -26,11 +26,11 @@ public class PipelineFactory : IPipelineFactory
2626
private readonly IEncoder _encoder;
2727
private readonly ISessionRefHolder _sessionRefHolder;
2828
private readonly IEnumerable<RequestFilter> _requestFilters;
29-
private readonly byte? _delimiter;
29+
private readonly IRequestDelimiter _delimiter;
3030

3131
public PipelineFactory(ISocketChannel channel, IDecoder decoder,
3232
IEncoder encoder, INetworkClient clientSession,
33-
IOptions<ServerConfiguration> configuration, ISessionRefHolder sessionRefHolder, IEnumerable<RequestFilter> requestFilters, byte? delimiter)
33+
IOptions<ServerConfiguration> configuration, ISessionRefHolder sessionRefHolder, IEnumerable<RequestFilter> requestFilters, IRequestDelimiter delimiter)
3434
{
3535
_channel = channel;
3636
_decoder = decoder;
@@ -52,10 +52,10 @@ public void CreatePipeline()
5252
pipeline.AddLast(filter);
5353
}
5454

55-
if (_delimiter != null)
55+
if (_delimiter.Delimiter != null)
5656
{
5757
pipeline.AddLast(new DelimiterBasedFrameDecoder(8192, new[] {
58-
Unpooled.WrappedBuffer(new[] { (byte)_delimiter })
58+
Unpooled.WrappedBuffer(new[] { (byte)_delimiter.Delimiter })
5959
}));
6060
}
6161

0 commit comments

Comments
 (0)