diff options
Diffstat (limited to 'lib/Net.Messaging.FBM/src/Server')
-rw-r--r-- | lib/Net.Messaging.FBM/src/Server/FBMListenerSessionParams.cs | 12 | ||||
-rw-r--r-- | lib/Net.Messaging.FBM/src/Server/FBMResponseMessage.cs | 6 |
2 files changed, 9 insertions, 9 deletions
diff --git a/lib/Net.Messaging.FBM/src/Server/FBMListenerSessionParams.cs b/lib/Net.Messaging.FBM/src/Server/FBMListenerSessionParams.cs index 0b4fa5b..435284b 100644 --- a/lib/Net.Messaging.FBM/src/Server/FBMListenerSessionParams.cs +++ b/lib/Net.Messaging.FBM/src/Server/FBMListenerSessionParams.cs @@ -1,5 +1,5 @@ /* -* Copyright (c) 2023 Vaughn Nugent +* Copyright (c) 2024 Vaughn Nugent * * Library: VNLib * Package: VNLib.Net.Messaging.FBM @@ -36,27 +36,27 @@ namespace VNLib.Net.Messaging.FBM.Server /// The size of the buffer to use while reading data from the websocket /// in the listener loop /// </summary> - public readonly int RecvBufferSize { get; init; } + public required readonly int RecvBufferSize { get; init; } /// <summary> /// The size of the buffer to store <see cref="FBMMessageHeader"/> values in /// the <see cref="FBMRequestMessage"/> /// </summary> - public readonly int MaxHeaderBufferSize { get; init; } + public required readonly int MaxHeaderBufferSize { get; init; } /// <summary> /// The size of the internal message response buffer when /// not streaming /// </summary> - public readonly int ResponseBufferSize { get; init; } + public required readonly int ResponseBufferSize { get; init; } /// <summary> /// The FMB message header character encoding /// </summary> - public readonly Encoding HeaderEncoding { get; init; } + public required readonly Encoding HeaderEncoding { get; init; } /// <summary> /// The absolute maxium size (in bytes) message to process before /// closing the websocket connection. This value should be negotiaed /// by clients or hard-coded to avoid connection issues /// </summary> - public readonly int MaxMessageSize { get; init; } + public required readonly int MaxMessageSize { get; init; } } } diff --git a/lib/Net.Messaging.FBM/src/Server/FBMResponseMessage.cs b/lib/Net.Messaging.FBM/src/Server/FBMResponseMessage.cs index 1e26140..2974d03 100644 --- a/lib/Net.Messaging.FBM/src/Server/FBMResponseMessage.cs +++ b/lib/Net.Messaging.FBM/src/Server/FBMResponseMessage.cs @@ -1,5 +1,5 @@ /* -* Copyright (c) 2023 Vaughn Nugent +* Copyright (c) 2024 Vaughn Nugent * * Library: VNLib * Package: VNLib.Net.Messaging.FBM @@ -47,7 +47,7 @@ namespace VNLib.Net.Messaging.FBM.Server } private readonly MessageSegmentEnumerator _messageEnumerator; - private readonly ISlindingWindowBuffer<byte> _headerAccumulator; + private readonly HeaderDataAccumulator _headerAccumulator; private readonly Encoding _headerEncoding; private IAsyncMessageBody? MessageBody; @@ -57,7 +57,7 @@ namespace VNLib.Net.Messaging.FBM.Server void IReusable.Prepare() { - (_headerAccumulator as HeaderDataAccumulator)!.Prepare(); + _headerAccumulator!.Prepare(); } bool IReusable.Release() |