make the stream types implement Send and Sync

Author: folkertdev

zlib-rs/src/deflate.rs

@@ -50,6 +50,9 @@ pub struct DeflateStream<'a> {
     pub(crate) reserved: crate::c_api::uLong,
 }
 
+unsafe impl Sync for DeflateStream<'_> {}
+unsafe impl Send for DeflateStream<'_> {}
+
 impl<'a> DeflateStream<'a> {
     // z_stream and DeflateStream must have the same layout. Do our best to check if this is true.
     // (imperfect check, but should catch most mistakes.)

zlib-rs/src/inflate.rs

@@ -50,6 +50,9 @@ pub struct InflateStream<'a> {
     pub(crate) reserved: crate::c_api::uLong,
 }
 
+unsafe impl Sync for InflateStream<'_> {}
+unsafe impl Send for InflateStream<'_> {}
+
 #[cfg(feature = "__internal-test")]
 #[doc(hidden)]
 pub const INFLATE_STATE_SIZE: usize = core::mem::size_of::<crate::inflate::State>();

zlib-rs/src/stable.rs

@@ -67,11 +67,6 @@ impl InflateError {
 /// The state that is used to decompress an input.
 pub struct Inflate(crate::inflate::InflateStream<'static>);
 
-// SAFETY: the stream contains raw pointers, but the `Deflate` API enforces
-// the correct aliasing and mutability constraints.
-unsafe impl Sync for Inflate {}
-unsafe impl Send for Inflate {}
-
 impl Inflate {
     /// The amount of bytes consumed from the input so far.
     pub fn total_in(&self) -> u64 {
@@ -195,11 +190,6 @@ impl From<ReturnCode> for Result<Status, DeflateError> {
 /// The state that is used to compress an input.
 pub struct Deflate(crate::deflate::DeflateStream<'static>);
 
-// SAFETY: the stream contains raw pointers, but the `Deflate` API enforces
-// the correct aliasing and mutability constraints.
-unsafe impl Sync for Deflate {}
-unsafe impl Send for Deflate {}
-
 impl Deflate {
     /// The number of bytes that were read from the input.
     pub fn total_in(&self) -> u64 {