Run cargo fmt

Author: filmor

rustler/src/thread.rs

@@ -1,8 +1,8 @@
 use crate::env::OwnedEnv;
-use std::panic;
-use std::thread;
 use crate::types::atom::Atom;
 use crate::{Encoder, Env, Term};
+use std::panic;
+use std::thread;
 
 /// A `JobSpawner` is a value that can run Rust code on non-Erlang system threads.
 /// Abstracts away details of thread management for `spawn()`.

rustler/src/types/binary.rs

@@ -1,9 +1,9 @@
 use crate::wrapper::binary::{alloc, realloc, ErlNifBinary};
 use crate::{Decoder, Encoder, Env, Error, NifResult, Term};
 
-use std::mem::MaybeUninit;
 use std::borrow::{Borrow, BorrowMut};
 use std::io::Write;
+use std::mem::MaybeUninit;
 use std::ops::{Deref, DerefMut};
 
 // Owned

rustler_codegen/src/ex_struct.rs

@@ -83,7 +83,11 @@ pub fn gen_decoder(
             let ident = field.ident.as_ref().unwrap();
             let ident_str = ident.to_string();
             let atom_fun = Ident::new(&format!("atom_{}", ident_str), Span::call_site());
-            let error_message = format!("Could not decode field :{} on %{}{{}}", ident.to_string(), struct_name.to_string());
+            let error_message = format!(
+                "Could not decode field :{} on %{}{{}}",
+                ident.to_string(),
+                struct_name.to_string()
+            );
             quote! {
                 #ident: match ::rustler::Decoder::decode(term.map_get(#atom_fun().encode(env))?) {
                     Err(_) => return Err(::rustler::Error::RaiseTerm(Box::new(#error_message))),

rustler_sys/src/initmacro.rs

@@ -350,7 +350,6 @@ mod initmacro_namespace_tests {
         });
         assert_eq!(0, funcs[0].flags);
     }
-
 }
 
 #[cfg(test)]
@@ -629,5 +628,4 @@ mod initmacro_tests {
         });
         assert_eq!(0, funcs[0].flags);
     }
-
 }