Adopt Sendable in NIOHTTPCompression (#172)

apple · Aug 23, 2022 · 1ef46c0 · 1ef46c0
1 parent 9697a61
commit 1ef46c0
Show file tree

Hide file tree

Showing 6 changed files with 22 additions and 2 deletions.
diff --git a/Sources/NIOHTTPCompression/HTTPCompression.swift b/Sources/NIOHTTPCompression/HTTPCompression.swift
@@ -19,7 +19,7 @@ import NIOCore
 public enum NIOCompression {
 
     /// Which algorithm should be used for compression.
-    public struct Algorithm: CustomStringConvertible, Equatable {
+    public struct Algorithm: CustomStringConvertible, Equatable, NIOSendable {
         fileprivate enum AlgorithmEnum: String {
             case gzip
             case deflate

diff --git a/Sources/NIOHTTPCompression/HTTPDecompression.swift b/Sources/NIOHTTPCompression/HTTPDecompression.swift
@@ -18,7 +18,7 @@ import NIOCore
 /// Namespace for decompression code.
 public enum NIOHTTPDecompression {
     /// Specifies how to limit decompression inflation.
-    public struct DecompressionLimit {
+    public struct DecompressionLimit: NIOSendable {
         private enum Limit {
             case none
             case size(Int)

diff --git a/Sources/NIOHTTPCompression/HTTPRequestCompressor.swift b/Sources/NIOHTTPCompression/HTTPRequestCompressor.swift
@@ -179,3 +179,7 @@ public final class NIOHTTPRequestCompressor: ChannelOutboundHandler, RemovableCh
     }
 }
 
+#if swift(>=5.6)
+@available(*, unavailable)
+extension NIOHTTPRequestCompressor: Sendable {}
+#endif
diff --git a/Sources/NIOHTTPCompression/HTTPRequestDecompressor.swift b/Sources/NIOHTTPCompression/HTTPRequestDecompressor.swift
@@ -89,3 +89,8 @@ public final class NIOHTTPRequestDecompressor: ChannelDuplexHandler, RemovableCh
         }
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension NIOHTTPRequestDecompressor: Sendable {}
+#endif
diff --git a/Sources/NIOHTTPCompression/HTTPResponseCompressor.swift b/Sources/NIOHTTPCompression/HTTPResponseCompressor.swift
@@ -221,6 +221,12 @@ public final class HTTPResponseCompressor: ChannelDuplexHandler, RemovableChanne
         pendingWritePromise = context.eventLoop.makePromise()
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension HTTPResponseCompressor: Sendable {}
+#endif
+
 /// A buffer object that allows us to keep track of how much of a HTTP response we've seen before
 /// a flush.
 ///

diff --git a/Sources/NIOHTTPCompression/HTTPResponseDecompressor.swift b/Sources/NIOHTTPCompression/HTTPResponseDecompressor.swift
@@ -105,3 +105,8 @@ public final class NIOHTTPResponseDecompressor: ChannelDuplexHandler, RemovableC
         }
     }
 }
+
+#if swift(>=5.6)
+@available(*, unavailable)
+extension NIOHTTPResponseDecompressor: Sendable {}
+#endif