diff --git a/Sources/NIOCore/Codec.swift b/Sources/NIOCore/Codec.swift index c4ef6a4a..8f62e42c 100644 --- a/Sources/NIOCore/Codec.swift +++ b/Sources/NIOCore/Codec.swift @@ -14,7 +14,7 @@ /// State of the current decoding process. -public enum DecodingState { +public enum DecodingState: NIOSendable { /// Continue decoding. case `continue` @@ -485,6 +485,11 @@ public final class ByteToMessageHandler { } } +#if swift(>=5.7) +@available(*, unavailable) +extension ByteToMessageHandler: Sendable {} +#endif + // MARK: ByteToMessageHandler: Test Helpers extension ByteToMessageHandler { internal var cumulationBuffer: ByteBuffer? { @@ -771,6 +776,11 @@ public final class MessageToByteHandler: ChannelO } } +#if swift(>=5.7) +@available(*, unavailable) +extension MessageToByteHandler: Sendable {} +#endif + extension MessageToByteHandler { public func handlerAdded(context: ChannelHandlerContext) { precondition(self.state.readyToBeAddedToChannel, diff --git a/Sources/NIOCore/SingleStepByteToMessageDecoder.swift b/Sources/NIOCore/SingleStepByteToMessageDecoder.swift index 1a77d1e8..ac979ad2 100644 --- a/Sources/NIOCore/SingleStepByteToMessageDecoder.swift +++ b/Sources/NIOCore/SingleStepByteToMessageDecoder.swift @@ -274,6 +274,10 @@ public final class NIOSingleStepByteToMessageProcessor=5.7) +@available(*, unavailable) +extension NIOSingleStepByteToMessageProcessor: Sendable {} +#endif // MARK: NIOSingleStepByteToMessageProcessor Public API extension NIOSingleStepByteToMessageProcessor {