bgzf/async: Use NonZeroUsize::MIN

zaeleus · Aug 25, 2024 · 802ed03 · 802ed03
1 parent 54e6d70
commit 802ed03
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 16 deletions.
diff --git a/noodles-bgzf/src/async/reader/builder.rs b/noodles-bgzf/src/async/reader/builder.rs
@@ -21,13 +21,9 @@ impl Builder {
     ///
     /// ```
     /// use std::num::NonZeroUsize;
-    ///
     /// use noodles_bgzf as bgzf;
-    ///
-    /// let worker_count = NonZeroUsize::try_from(1)?;
     /// let builder = bgzf::r#async::reader::Builder::default()
-    ///     .set_worker_count(worker_count);
-    /// # Ok::<_, std::num::TryFromIntError>(())
+    ///     .set_worker_count(NonZeroUsize::MIN);
     /// ```
     pub fn set_worker_count(mut self, worker_count: NonZeroUsize) -> Self {
         self.worker_count = Some(worker_count);
@@ -48,9 +44,9 @@ impl Builder {
     where
         R: AsyncRead,
     {
-        let worker_count = self.worker_count.unwrap_or_else(|| {
-            thread::available_parallelism().unwrap_or_else(|_| NonZeroUsize::new(1).unwrap())
-        });
+        let worker_count = self
+            .worker_count
+            .unwrap_or_else(|| thread::available_parallelism().unwrap_or(NonZeroUsize::MIN));
 
         Reader {
             stream: Some(Inflater::new(reader).try_buffered(worker_count.get())),

diff --git a/noodles-bgzf/src/async/writer/builder.rs b/noodles-bgzf/src/async/writer/builder.rs
@@ -44,13 +44,9 @@ impl Builder {
     ///
     /// ```
     /// use std::num::NonZeroUsize;
-    ///
     /// use noodles_bgzf as bgzf;
-    ///
-    /// let worker_count = NonZeroUsize::try_from(1)?;
     /// let builder = bgzf::r#async::writer::Builder::default()
-    ///     .set_worker_count(worker_count);
-    /// # Ok::<_, std::num::TryFromIntError>(())
+    ///     .set_worker_count(NonZeroUsize::MIN);
     /// ```
     pub fn set_worker_count(mut self, worker_count: NonZeroUsize) -> Self {
         self.worker_count = Some(worker_count);
@@ -73,9 +69,9 @@ impl Builder {
     {
         let compression_level = self.compression_level.unwrap_or_default();
 
-        let worker_count = self.worker_count.unwrap_or_else(|| {
-            thread::available_parallelism().unwrap_or_else(|_| NonZeroUsize::new(1).unwrap())
-        });
+        let worker_count = self
+            .worker_count
+            .unwrap_or_else(|| thread::available_parallelism().unwrap_or(NonZeroUsize::MIN));
 
         Writer {
             sink: Deflater::new(FramedWrite::new(writer, BlockCodec)).buffer(worker_count.get()),