BLD: Upgrade Rust version to 1.83

c/src/decode.rs

@@ -54,7 +54,7 @@ pub unsafe extern "C" fn DbnDecoder_metadata(decoder: *mut Decoder) -> *const Me
 #[no_mangle]
 pub unsafe extern "C" fn DbnDecoder_decode(decoder: *mut Decoder) -> *const RecordHeader {
     if let Some(Ok(Some(rec))) = decoder.as_mut().map(|d| d.decode_record_ref()) {
-        return rec.header();
+        rec.header()
     } else {
         null()
     }

rust/dbn-cli/tests/integration_tests.rs

@@ -580,11 +580,12 @@ fn broken_pipe_is_silent(
     if !fragment_flag.is_empty() {
         dbn_cmd.arg(fragment_flag);
     }
-    let dbn_res = dbn_cmd
+    let mut dbn_res = dbn_cmd
         .stdout(process::Stdio::piped())
         .stderr(process::Stdio::piped())
         .spawn()
         .unwrap();
+    dbn_res.wait().unwrap();
     let mut false_cmd = process::Command::new("false");
     false_cmd.stdin(dbn_res.stdout.unwrap());
     Command::from_std(false_cmd)

rust/dbn/src/decode.rs

@@ -126,7 +126,7 @@ where
     LegacyDbz(dbz::Decoder<R>),
 }
 
-impl<'a, R> DynDecoder<'a, BufReader<R>>
+impl<R> DynDecoder<'_, BufReader<R>>
 where
     R: io::Read,
 {
@@ -156,7 +156,7 @@ where
     }
 }
 
-impl<'a, R> DynDecoder<'a, R>
+impl<R> DynDecoder<'_, R>
 where
     R: io::BufRead,
 {
@@ -223,7 +223,7 @@ where
     }
 }
 
-impl<'a> DynDecoder<'a, BufReader<File>> {
+impl DynDecoder<'_, BufReader<File>> {
     /// Creates a new [`DynDecoder`] from the file at `path`. It will decode records
     /// from previous DBN versions according to `upgrade_policy`.
     ///
@@ -247,7 +247,7 @@ impl<'a> DynDecoder<'a, BufReader<File>> {
     }
 }
 
-impl<'a, R> DecodeRecordRef for DynDecoder<'a, R>
+impl<R> DecodeRecordRef for DynDecoder<'_, R>
 where
     R: io::BufRead,
 {
@@ -261,7 +261,7 @@ where
 }
 
 #[allow(deprecated)]
-impl<'a, R> DbnMetadata for DynDecoder<'a, R>
+impl<R> DbnMetadata for DynDecoder<'_, R>
 where
     R: io::BufRead,
 {
@@ -283,7 +283,7 @@ where
 }
 
 #[allow(deprecated)]
-impl<'a, R> DecodeRecord for DynDecoder<'a, R>
+impl<R> DecodeRecord for DynDecoder<'_, R>
 where
     R: io::BufRead,
 {
@@ -296,7 +296,7 @@ where
     }
 }
 
-impl<'a, R> DecodeStream for DynDecoder<'a, R>
+impl<R> DecodeStream for DynDecoder<'_, R>
 where
     R: io::BufRead,
 {
@@ -322,7 +322,7 @@ where
     ZStd(::zstd::stream::Decoder<'a, R>),
 }
 
-impl<'a, R> DynReader<'a, BufReader<R>>
+impl<R> DynReader<'_, BufReader<R>>
 where
     R: io::Read,
 {
@@ -348,7 +348,7 @@ where
     }
 }
 
-impl<'a, R> DynReader<'a, R>
+impl<R> DynReader<'_, R>
 where
     R: io::BufRead,
 {
@@ -403,7 +403,7 @@ where
     }
 }
 
-impl<'a> DynReader<'a, BufReader<File>> {
+impl DynReader<'_, BufReader<File>> {
     /// Creates a new [`DynReader`] from the file at `path`.
     ///
     /// # Errors
@@ -423,7 +423,7 @@ impl<'a> DynReader<'a, BufReader<File>> {
     }
 }
 
-impl<'a, R> io::Read for DynReader<'a, R>
+impl<R> io::Read for DynReader<'_, R>
 where
     R: io::BufRead,
 {
@@ -435,7 +435,7 @@ where
     }
 }
 
-impl<'a, R> private::BufferSlice for DynDecoder<'a, R>
+impl<R> private::BufferSlice for DynDecoder<'_, R>
 where
     R: io::BufRead,
 {

rust/dbn/src/decode/dbn/async.rs

@@ -111,7 +111,7 @@ where
     /// # Cancel safety
     /// This method is cancel safe. It can be used within a `tokio::select!` statement
     /// without the potential for corrupting the input stream.
-    pub async fn decode_record<'a, T: HasRType + 'a>(&'a mut self) -> Result<Option<&T>> {
+    pub async fn decode_record<'a, T: HasRType + 'a>(&'a mut self) -> Result<Option<&'a T>> {
         self.decoder.decode().await
     }
 
@@ -310,7 +310,7 @@ where
     /// # Cancel safety
     /// This method is cancel safe. It can be used within a `tokio::select!` statement
     /// without the potential for corrupting the input stream.
-    pub async fn decode<'a, T: HasRType + 'a>(&'a mut self) -> Result<Option<&T>> {
+    pub async fn decode<'a, T: HasRType + 'a>(&'a mut self) -> Result<Option<&'a T>> {
         let rec_ref = self.decode_ref().await?;
         if let Some(rec_ref) = rec_ref {
             rec_ref

rust/dbn/src/decode/dbn/sync.rs

@@ -91,7 +91,7 @@ where
     }
 }
 
-impl<'a, R> Decoder<zstd::stream::Decoder<'a, BufReader<R>>>
+impl<R> Decoder<zstd::stream::Decoder<'_, BufReader<R>>>
 where
     R: io::Read,
 {
@@ -107,7 +107,7 @@ where
     }
 }
 
-impl<'a, R> Decoder<zstd::stream::Decoder<'a, R>>
+impl<R> Decoder<zstd::stream::Decoder<'_, R>>
 where
     R: io::BufRead,
 {
@@ -140,7 +140,7 @@ impl Decoder<BufReader<File>> {
     }
 }
 
-impl<'a> Decoder<zstd::stream::Decoder<'a, BufReader<File>>> {
+impl Decoder<zstd::stream::Decoder<'_, BufReader<File>>> {
     /// Creates a DBN [`Decoder`] from the Zstandard-compressed file at `path`.
     ///
     /// # Errors

rust/dbn/src/encode/dbn/sync.rs

@@ -46,7 +46,7 @@ where
     }
 }
 
-impl<'a, W> Encoder<zstd::stream::AutoFinishEncoder<'a, W>>
+impl<W> Encoder<zstd::stream::AutoFinishEncoder<'_, W>>
 where
     W: io::Write,
 {

rust/dbn/src/encode/dyn_encoder.rs

@@ -155,7 +155,7 @@ where
     }
 }
 
-impl<'a, W> DynEncoder<'a, W>
+impl<W> DynEncoder<'_, W>
 where
     W: io::Write,
 {
@@ -230,7 +230,7 @@ where
     }
 }
 
-impl<'a, W> EncodeRecord for DynEncoder<'a, W>
+impl<W> EncodeRecord for DynEncoder<'_, W>
 where
     W: io::Write,
 {
@@ -243,7 +243,7 @@ where
     }
 }
 
-impl<'a, W> EncodeRecordRef for DynEncoder<'a, W>
+impl<W> EncodeRecordRef for DynEncoder<'_, W>
 where
     W: io::Write,
 {
@@ -256,7 +256,7 @@ where
     }
 }
 
-impl<'a, W> EncodeDbn for DynEncoder<'a, W>
+impl<W> EncodeDbn for DynEncoder<'_, W>
 where
     W: io::Write,
 {
@@ -276,7 +276,7 @@ where
     }
 }
 
-impl<'a, W> EncodeRecordTextExt for DynEncoder<'a, W>
+impl<W> EncodeRecordTextExt for DynEncoder<'_, W>
 where
     W: io::Write,
 {
@@ -289,7 +289,7 @@ where
     }
 }
 
-impl<'a, W> EncodeRecord for DynEncoderImpl<'a, W>
+impl<W> EncodeRecord for DynEncoderImpl<'_, W>
 where
     W: io::Write,
 {
@@ -310,7 +310,7 @@ where
     }
 }
 
-impl<'a, W> EncodeRecordRef for DynEncoderImpl<'a, W>
+impl<W> EncodeRecordRef for DynEncoderImpl<'_, W>
 where
     W: io::Write,
 {
@@ -331,7 +331,7 @@ where
     }
 }
 
-impl<'a, W> EncodeDbn for DynEncoderImpl<'a, W>
+impl<W> EncodeDbn for DynEncoderImpl<'_, W>
 where
     W: io::Write,
 {
@@ -363,7 +363,7 @@ where
     }
 }
 
-impl<'a, W> EncodeRecordTextExt for DynEncoderImpl<'a, W>
+impl<W> EncodeRecordTextExt for DynEncoderImpl<'_, W>
 where
     W: io::Write,
 {

rust/dbn/src/encode/dyn_writer.rs

@@ -17,7 +17,7 @@ where
     Zstd(zstd::stream::AutoFinishEncoder<'a, W>),
 }
 
-impl<'a, W> DynWriter<'a, W>
+impl<W> DynWriter<'_, W>
 where
     W: io::Write,
 {
@@ -41,7 +41,7 @@ where
     }
 }
 
-impl<'a, W> io::Write for DynWriter<'a, W>
+impl<W> io::Write for DynWriter<'_, W>
 where
     W: io::Write,
 {

rust/dbn/src/record_enum.rs

@@ -104,7 +104,7 @@ impl<'a> From<&'a RecordEnum> for RecordRefEnum<'a> {
     }
 }
 
-impl<'a> RecordRefEnum<'a> {
+impl RecordRefEnum<'_> {
     /// Converts the reference enum into an owned enum value.
     pub fn to_owned(&self) -> RecordEnum {
         #[allow(clippy::clone_on_copy)] // required for when trivial_copy feature is disabled
@@ -382,7 +382,7 @@ impl RecordMut for RecordEnum {
     }
 }
 
-impl<'a> Record for RecordRefEnum<'a> {
+impl Record for RecordRefEnum<'_> {
     fn header(&self) -> &crate::RecordHeader {
         match self {
             RecordRefEnum::Mbo(rec) => rec.header(),

rust/dbn/src/record_ref.rs

@@ -194,7 +194,7 @@ impl<'a> From<RecordRefEnum<'a>> for RecordRef<'a> {
     }
 }
 
-impl<'a> Debug for RecordRef<'a> {
+impl Debug for RecordRef<'_> {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         f.debug_struct("RecordRef")
             .field(