Adopt Sendable in NIOExtras (#174)

Incremental `Sendable` adoption. Co-authored-by: Cory Benfield <lukasa@apple.com>
apple · Aug 23, 2022 · 5334d94 · 5334d94
1 parent b64e599
commit 5334d94
Show file tree

Hide file tree

Showing 11 changed files with 58 additions and 1 deletion.
diff --git a/Sources/NIOExtras/DebugInboundEventsHandler.swift b/Sources/NIOExtras/DebugInboundEventsHandler.swift
@@ -174,3 +174,8 @@ public class DebugInboundEventsHandler: ChannelInboundHandler {
         fflush(stdout)
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension DebugInboundEventsHandler: Sendable {}
+#endif
diff --git a/Sources/NIOExtras/DebugOutboundEventsHandler.swift b/Sources/NIOExtras/DebugOutboundEventsHandler.swift
@@ -170,3 +170,8 @@ public class DebugOutboundEventsHandler: ChannelOutboundHandler {
         fflush(stdout)
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension DebugOutboundEventsHandler: Sendable {}
+#endif
diff --git a/Sources/NIOExtras/FixedLengthFrameDecoder.swift b/Sources/NIOExtras/FixedLengthFrameDecoder.swift
@@ -76,3 +76,8 @@ public final class FixedLengthFrameDecoder: ByteToMessageDecoder {
         return .needMoreData
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension FixedLengthFrameDecoder: Sendable {}
+#endif
diff --git a/Sources/NIOExtras/JSONRPCFraming+ContentLengthHeader.swift b/Sources/NIOExtras/JSONRPCFraming+ContentLengthHeader.swift
@@ -214,3 +214,13 @@ extension String {
         return self[firstElementIndex ..< lastElementIndex.base]
     }
 }
+
+
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension NIOJSONRPCFraming.ContentLengthHeaderFrameDecoder: Sendable {}
+
+@available(*, unavailable)
+extension NIOJSONRPCFraming.ContentLengthHeaderFrameEncoder: Sendable {}
+#endif
diff --git a/Sources/NIOExtras/LengthFieldBasedFrameDecoder.swift b/Sources/NIOExtras/LengthFieldBasedFrameDecoder.swift
@@ -246,3 +246,8 @@ public final class LengthFieldBasedFrameDecoder: ByteToMessageDecoder {
         return frameLength
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension LengthFieldBasedFrameDecoder: Sendable {}
+#endif
diff --git a/Sources/NIOExtras/LengthFieldPrepender.swift b/Sources/NIOExtras/LengthFieldPrepender.swift
@@ -144,3 +144,8 @@ public final class LengthFieldPrepender: ChannelOutboundHandler {
         context.write(data, promise: promise)
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension LengthFieldPrepender: Sendable {}
+#endif
diff --git a/Sources/NIOExtras/LineBasedFrameDecoder.swift b/Sources/NIOExtras/LineBasedFrameDecoder.swift
@@ -91,3 +91,8 @@ public class LineBasedFrameDecoder: ByteToMessageDecoder {
         return nil
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension LineBasedFrameDecoder: Sendable {}
+#endif
diff --git a/Sources/NIOExtras/NIOLengthFieldBitLength.swift b/Sources/NIOExtras/NIOLengthFieldBitLength.swift
@@ -12,8 +12,10 @@
 //
 //===----------------------------------------------------------------------===//
 
+import NIOCore
+
 /// A struct to describe the length of a piece of data in bits
-public struct NIOLengthFieldBitLength {
+public struct NIOLengthFieldBitLength: NIOSendable {
     internal enum Backing {
         case bits8
         case bits16

diff --git a/Sources/NIOExtras/PCAPRingBuffer.swift b/Sources/NIOExtras/PCAPRingBuffer.swift
@@ -96,3 +96,8 @@ public class NIOPCAPRingBuffer {
         return toReturn
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension NIOPCAPRingBuffer: Sendable {}
+#endif
diff --git a/Sources/NIOExtras/RequestResponseHandler.swift b/Sources/NIOExtras/RequestResponseHandler.swift
@@ -119,3 +119,8 @@ public final class RequestResponseHandler<Request, Response>: ChannelDuplexHandl
         }
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension RequestResponseHandler: Sendable {}
+#endif
diff --git a/Sources/NIOExtras/WritePCAPHandler.swift b/Sources/NIOExtras/WritePCAPHandler.swift
@@ -290,6 +290,11 @@ public class NIOWritePCAPHandler: RemovableChannelHandler {
     }
 }
 
+#if swift(>=5.6)
+@available(*, unavailable)
+extension NIOWritePCAPHandler: Sendable {}
+#endif
+
 extension NIOWritePCAPHandler: ChannelDuplexHandler {
     public typealias InboundIn = ByteBuffer
     public typealias InboundOut = ByteBuffer