rustfmt

Author: Quba1

src/codes_file/iterator.rs

@@ -72,17 +72,17 @@ impl<'ch, D: Debug> FallibleIterator for RefMessageIter<'ch, D> {
 ///
 /// `ArcMessage` implements `Send + Sync` so it can be both moved to thread (for example, to read messages in parallel)
 /// or shared across threads (when wrapped in [`Arc`]).
-/// 
+///
 /// This structure implements [`FallibleIterator`] - see the documentation for information how that differs from a standard `Iter`.
 ///
 /// Creating this iter does not require `CodesFile` to be mutable, because it takes ownership over the `CodesFile`.
 ///
 /// If you don't need to share the message, use [`RefMessageIter`] to avoid the performance overhead of [`Arc`].
-/// 
+///
 /// If you want to modify the message, use [`try_clone()`](RefMessage::try_clone).
-/// 
+///
 /// ## Example
-/// 
+///
 /// See the second example in the main crate description for example usage of `ArcMessageIter`.
 #[derive(Debug)]
 pub struct ArcMessageIter<D: Debug> {
@@ -106,9 +106,9 @@ impl<D: Debug> FallibleIterator for ArcMessageIter<D> {
     ///
     /// The method will return [`CodesInternal`](crate::errors::CodesInternal)
     /// when internal ecCodes function returns non-zero code.
-    /// 
+    ///
     /// # Panics
-    /// 
+    ///
     /// This method internally uses a Mutex to access `CodesFile`, which can panic when poisoned,
     /// but thers is no path in which you can get to the state of poisoned mutex, while still able to access this method.
     fn next(&mut self) -> Result<Option<Self::Item>, Self::Error> {

src/codes_message/mod.rs

@@ -43,9 +43,9 @@ use crate::{CodesFile, intermediate_bindings::codes_handle_delete};
 /// You can read a `Key` with static types using [`read_key()`](KeyRead::read_key()) or with [`DynamicKeyType`] using[`read_key_dynamic()`](CodesMessage::read_key_dynamic())
 /// To iterate over all key names use [`KeysIterator`](crate::KeysIterator). You can also modify the message using
 /// [`write_key_unchecked()`](KeyWrite::write_key_unchecked()) (only available for `BufMessage`).
-/// 
+///
 /// [`CodesNearest`](crate::CodesNearest) can be used to find nearest gridpoints for given coordinates in the `CodesMessage`.
-/// 
+///
 /// To write the message to file use [`write_to_file()`](CodesMessage::write_to_file).
 ///
 /// If you are interested only in getting data values from the message you can use

src/intermediate_bindings/codes_set.rs

@@ -53,12 +53,8 @@ pub unsafe fn codes_set_long_array(
 
         let length = values.len();
 
-        let error_code = eccodes_sys::codes_set_long_array(
-            handle,
-            key.as_ptr(),
-            values.as_ptr().cast(),
-            length,
-        );
+        let error_code =
+            eccodes_sys::codes_set_long_array(handle, key.as_ptr(), values.as_ptr().cast(), length);
         error_code_to_result(error_code)?;
 
         Ok(())

src/intermediate_bindings/mod.rs

@@ -30,9 +30,7 @@ pub use codes_get::{
     codes_get_long_array, codes_get_message, codes_get_native_type, codes_get_size,
     codes_get_string,
 };
-pub use codes_handle::{
-    codes_handle_clone, codes_handle_delete, codes_handle_new_from_file,
-};
+pub use codes_handle::{codes_handle_clone, codes_handle_delete, codes_handle_new_from_file};
 pub use codes_keys::{
     codes_keys_iterator_delete, codes_keys_iterator_get_name, codes_keys_iterator_new,
     codes_keys_iterator_next,

src/keys_iterator.rs

@@ -33,9 +33,9 @@ use crate::{
 /// # fn main() -> anyhow::Result<()> {
 /// let mut handle = CodesFile::new_from_file("./data/iceland.grib", ProductKind::GRIB)?;
 /// let mut current_message = handle.ref_message_iter().next()?.context("no message")?;
-/// 
+///
 /// let mut keys_iter = current_message.default_keys_iterator()?;
-/// 
+///
 /// while let Some(key_name) = keys_iter.next()? {
 ///     println!("{key_name}");
 /// }

src/lib.rs

@@ -178,26 +178,26 @@
 //! use anyhow::Context;
 //! use eccodes::{CodesFile, FallibleIterator, KeyRead, KeyWrite, ProductKind};
 //! use std::{collections::HashMap, fs::remove_file, path::Path};
-//! 
+//!
 //! # fn main() -> anyhow::Result<()> {
 //! // Start by opening the file and creating CodesFile
 //! let file_path = Path::new("./data/iceland-levels.grib");
 //! let mut handle = CodesFile::new_from_file(file_path, ProductKind::GRIB)?;
-//! 
+//!
 //! // To build the index we need to collect all messages
 //! let messages = handle.ref_message_iter().collect::<Vec<_>>()?;
 //! let mut msg_index = HashMap::new();
 //! msg_index.reserve(messages.len());
-//! 
+//!
 //! // Now we can put the messages into a hashmap and index them by shortName and level
 //! for msg in messages.into_iter() {
 //!     // all messages in this grib are on the same level type
 //!     let short_name: String = msg.read_key("shortName")?;
 //!     let level: i64 = msg.read_key("level")?;
-//! 
+//!
 //!     msg_index.insert((short_name, level), msg);
 //! }
-//! 
+//!
 //! // Now we can get the values from messages we need
 //! let t_800: Vec<f64> = msg_index
 //!     .get(&("t".to_string(), 800))
@@ -207,24 +207,24 @@
 //!     .get(&("t".to_string(), 800))
 //!     .context("message missing")?
 //!     .read_key("values")?;
-//! 
+//!
 //! // We will also clone t at 700hPa to edit it
 //! let mut t_850_msg = msg_index
 //!     .get(&("t".to_string(), 700))
 //!     .context("message missing")?
 //!     .try_clone()?;
-//! 
+//!
 //! // Compute temperature at 850hPa
 //! let t_850_values: Vec<f64> = t_800
 //!     .iter()
 //!     .zip(t_900.iter())
 //!     .map(|t| (t.0 + t.1) / 2.0)
 //!     .collect();
-//! 
+//!
 //! // Edit appropriate keys in the cloned (editable) message
 //! t_850_msg.write_key_unchecked("level", 850)?;
 //! t_850_msg.write_key_unchecked("values", t_850_values.as_slice())?;
-//! 
+//!
 //! // Save the message to a new file without appending
 //! t_850_msg.write_to_file(Path::new("iceland-850.grib"), false)?;
 //!    #  remove_file(Path::new("iceland-850.grib")).unwrap();
@@ -233,7 +233,7 @@
 //! ```
 //!
 //! ## Changes in version 0.14
-//! 
+//!
 //! 1. `experimental_index` feature has been removed - users are encouraged to create their own indexes as shown above or use iterator filtering
 //! 2. `message_ndarray` feature has been renamed to `ndarray`
 //! 3. `CodesHandle` has been renamed to `CodesFile`
@@ -266,7 +266,7 @@ pub mod keys_iterator;
 mod pointer_guard;
 
 pub use codes_file::{ArcMessageIter, CodesFile, ProductKind, RefMessageIter};
-pub use codes_message::{ArcMessage, BufMessage, KeyRead, KeyWrite, RefMessage, DynamicKeyType};
+pub use codes_message::{ArcMessage, BufMessage, DynamicKeyType, KeyRead, KeyWrite, RefMessage};
 pub use codes_nearest::{CodesNearest, NearestGridpoint};
 pub use errors::CodesError;
 pub use fallible_iterator::{FallibleIterator, IntoFallibleIterator};

tests/example.rs

@@ -1,13 +1,13 @@
 use anyhow::Context;
 use eccodes::{CodesFile, FallibleIterator, ProductKind};
 fn main() -> anyhow::Result<()> {
-let mut handle = CodesFile::new_from_file("./data/iceland.grib", ProductKind::GRIB)?;
-let mut current_message = handle.ref_message_iter().next()?.context("no message")?;
+    let mut handle = CodesFile::new_from_file("./data/iceland.grib", ProductKind::GRIB)?;
+    let mut current_message = handle.ref_message_iter().next()?.context("no message")?;
 
-let mut keys_iter = current_message.default_keys_iterator()?;
+    let mut keys_iter = current_message.default_keys_iterator()?;
 
-while let Some(key_name) = keys_iter.next()? {
-    println!("{key_name}");
-}
-Ok(())
+    while let Some(key_name) = keys_iter.next()? {
+        println!("{key_name}");
+    }
+    Ok(())
 }