Replace into_py_any(py).unwrap() with into_any_py(py)?

Author: clin1234

rust-ext/src/buffers.rs

@@ -242,7 +242,7 @@ impl ZstdBufferWithSegments {
         }
 
         Ok(Self {
-            source: data.into_py_any(py).unwrap(),
+            source: data.into_py_any(py)?,
             buffer: data_buffer,
             segments,
         })
@@ -344,7 +344,7 @@ impl ZstdBufferWithSegmentsCollection {
 
             offset += segment.segments.len();
 
-            buffers.push(item.into_py_any(py).unwrap());
+            buffers.push(item.into_py_any(py)?);
             first_elements.push(offset);
         }
 

rust-ext/src/compression_chunker.rs

@@ -225,7 +225,7 @@ impl ZstdCompressionChunkerIterator {
                 let chunk = PyBytes::new(py, &slf.dest_buffer);
                 slf.dest_buffer.clear();
 
-                return Ok(Some(chunk.into_py_any(py).unwrap()));
+                return Ok(Some(chunk.into_py_any(py)?));
             }
 
             // Else continue to compress available input data.
@@ -278,6 +278,6 @@ impl ZstdCompressionChunkerIterator {
         let chunk = PyBytes::new(py, &slf.dest_buffer);
         slf.dest_buffer.clear();
 
-        Ok(Some(chunk.into_py_any(py).unwrap()))
+        Ok(Some(chunk.into_py_any(py)?))
     }
 }

rust-ext/src/compression_writer.rs

@@ -48,7 +48,7 @@ impl ZstdCompressionWriter {
 
         Ok(Self {
             cctx,
-            writer: writer.into_py_any(py).unwrap(),
+            writer: writer.into_py_any(py)?,
             write_return_read,
             closefd,
             entered: false,

rust-ext/src/compressor_iterator.rs

@@ -60,7 +60,7 @@ impl ZstdCompressorIterator {
                 // TODO avoid buffer copy
                 let chunk = PyBytes::new(py, &dest_buffer);
 
-                return Ok(Some(chunk.into_py_any(py).unwrap()));
+                return Ok(Some(chunk.into_py_any(py)?));
             }
 
             // Else read another chunk in hopes of producing output data.
@@ -94,7 +94,7 @@ impl ZstdCompressorIterator {
             // TODO avoid buffer copy.
             let chunk = PyBytes::new(py, &dest_buffer);
 
-            return Ok(Some(chunk.into_py_any(py).unwrap()));
+            return Ok(Some(chunk.into_py_any(py)?));
         }
 
         Ok(None)

rust-ext/src/decompression_writer.rs

@@ -40,7 +40,7 @@ impl ZstdDecompressionWriter {
     ) -> PyResult<Self> {
         Ok(Self {
             dctx,
-            writer: writer.into_py_any(py).unwrap(),
+            writer: writer.into_py_any(py)?,
             write_size,
             write_return_read,
             closefd,

rust-ext/src/decompressor_iterator.rs

@@ -60,7 +60,7 @@ impl ZstdDecompressorIterator {
             if !dest_buffer.is_empty() {
                 // TODO avoid buffer copy.
                 let chunk = PyBytes::new(py, &dest_buffer);
-                return Ok(Some(chunk.into_py_any(py).unwrap()));
+                return Ok(Some(chunk.into_py_any(py)?));
             }
 
             // Repeat loop to collect more input data.
@@ -71,7 +71,7 @@ impl ZstdDecompressorIterator {
         if !dest_buffer.is_empty() {
             // TODO avoid buffer copy.
             let chunk = PyBytes::new(py, &dest_buffer);
-            Ok(Some(chunk.into_py_any(py).unwrap()))
+            Ok(Some(chunk.into_py_any(py)?))
         } else {
             Ok(None)
         }

rust-ext/src/stream.rs

@@ -139,7 +139,7 @@ pub(crate) fn make_in_buffer_source(
 ) -> PyResult<Box<dyn InBufferSource + Send>> {
     if source.hasattr("read")? {
         Ok(Box::new(ReadSource {
-            source: source.into_py_any(py).unwrap(),
+            source: source.into_py_any(py)?,
             buffer: None,
             read_size,
             finished: false,
@@ -153,7 +153,7 @@ pub(crate) fn make_in_buffer_source(
         })?;
 
         Ok(Box::new(BufferSource {
-            source: source.into_py_any(py).unwrap(),
+            source: source.into_py_any(py)?,
             buffer,
             offset: 0,
         }))