fix: formatting

Author: mibes

couch_rs/examples/basic_operations/main.rs

@@ -12,7 +12,7 @@
 /// automatically assigned IP address. Minikube for example generates a unique IP on start-up. You
 /// can obtain it with: `minikube ip`
 use couch_rs::types::find::FindQuery;
-use serde_json::{json, Value};
+use serde_json::{Value, json};
 use std::error::Error;
 
 const TEST_DB: &str = "test_db";

couch_rs/examples/typed_documents/main.rs

@@ -1,7 +1,7 @@
 #![allow(clippy::pub_underscore_fields)]
 #![allow(clippy::used_underscore_binding)]
 
-use couch_rs::{document::TypedCouchDocument, types::document::DocumentId, CouchDocument};
+use couch_rs::{CouchDocument, document::TypedCouchDocument, types::document::DocumentId};
 use serde::{Deserialize, Serialize};
 
 const TEST_DB: &str = "test_db";

couch_rs/src/changes.rs

@@ -4,7 +4,7 @@ use crate::{
     types::changes::{ChangeEvent, Event},
 };
 use futures_core::{Future, Stream};
-use futures_util::{ready, FutureExt, StreamExt, TryStreamExt};
+use futures_util::{FutureExt, StreamExt, TryStreamExt, ready};
 use reqwest::{Method, Response, StatusCode};
 use std::{
     collections::HashMap,
@@ -36,8 +36,8 @@ pub struct ChangesStream {
 
 enum ChangesStreamState {
     Idle,
-    Requesting(Pin<Box<dyn Future<Output=CouchResult<Response>> + Send + Sync + 'static>>),
-    Reading(Pin<Box<dyn Stream<Item=io::Result<String>> + Send + Sync + 'static>>),
+    Requesting(Pin<Box<dyn Future<Output = CouchResult<Response>> + Send + Sync + 'static>>),
+    Reading(Pin<Box<dyn Stream<Item = io::Result<String>> + Send + Sync + 'static>>),
 }
 
 impl ChangesStream {
@@ -186,7 +186,7 @@ impl Stream for ChangesStream {
 mod tests {
     use crate::client::Client;
     use futures_util::StreamExt;
-    use serde_json::{json, Value};
+    use serde_json::{Value, json};
     use tokio::join;
 
     #[tokio::test]

couch_rs/src/document.rs

@@ -1,4 +1,4 @@
-use serde::{de::DeserializeOwned, Deserialize, Serialize};
+use serde::{Deserialize, Serialize, de::DeserializeOwned};
 use serde_json::Value;
 use std::{
     borrow::Cow,

couch_rs/src/lib.rs

@@ -168,9 +168,7 @@ mod macros {
 
     /// Gets milliseconds from timespec
     macro_rules! tspec_ms {
-        ($tspec:ident) => {{
-            $tspec.sec * 1000 + $tspec.nsec as i64 / 1000000
-        }};
+        ($tspec:ident) => {{ $tspec.sec * 1000 + $tspec.nsec as i64 / 1000000 }};
     }
 
     /// Gets current UNIX time in milliseconds
@@ -183,9 +181,7 @@ mod macros {
 
     /// Url encode path segments
     macro_rules! url_encode {
-        ($id:ident) => {{
-            url::form_urlencoded::byte_serialize($id.as_bytes()).collect::<String>()
-        }};
+        ($id:ident) => {{ url::form_urlencoded::byte_serialize($id.as_bytes()).collect::<String>() }};
     }
 }
 
@@ -217,7 +213,7 @@ pub use client::Client;
 #[cfg(test)]
 mod couch_rs_tests {
     use crate as couch_rs;
-    use couch_rs::{document::TypedCouchDocument, types::document::DocumentId, CouchDocument};
+    use couch_rs::{CouchDocument, document::TypedCouchDocument, types::document::DocumentId};
     use serde::{Deserialize, Serialize};
     use std::borrow::Cow;
 
@@ -574,7 +570,7 @@ mod couch_rs_tests {
                 view::{CouchFunc, CouchViews, ViewCollection},
             },
         };
-        use serde_json::{json, Value};
+        use serde_json::{Value, json};
         use tokio::sync::{
             mpsc,
             mpsc::{Receiver, Sender},
@@ -1116,13 +1112,14 @@ mod couch_rs_tests {
 
                this will fail to deserialize if ViewItem.key is a String. It needs to be a Value to cover for all json scenarios
             */
-            assert!(db
-                .create_view(
+            assert!(
+                db.create_view(
                     view_name,
                     CouchViews::new(view_name, CouchFunc::new(count_by_id, Some("_count"))),
                 )
                 .await
-                .is_ok());
+                .is_ok()
+            );
 
             assert!(db.query_raw(view_name, view_name, None).await.is_ok());
 

couch_rs/src/model.rs

@@ -1,6 +1,6 @@
 use crate::document::TypedCouchDocument;
 use serde::ser::Serialize;
-use serde_json::{from_value, to_value, Value};
+use serde_json::{Value, from_value, to_value};
 
 /// Trait that provides methods that can be used to switch between abstract `Value` and concrete `Model` implementors (such as your custom data models)
 pub trait Model<T: TypedCouchDocument> {

couch_rs/src/typed.rs

@@ -13,7 +13,7 @@ use crate::{
         view::ViewCollection,
     },
 };
-use serde::{de::DeserializeOwned, Serialize};
+use serde::{Serialize, de::DeserializeOwned};
 use serde_json::Value;
 use std::marker::PhantomData;
 use tokio::sync::mpsc::Sender;

couch_rs/src/types/query.rs

@@ -1,6 +1,6 @@
 use super::document::DocumentId;
 use crate::{document::TypedCouchDocument, types::view::ViewCollection};
-use serde::{de::DeserializeOwned, Deserialize, Serialize};
+use serde::{Deserialize, Serialize, de::DeserializeOwned};
 
 #[derive(Serialize, Deserialize, PartialEq, Eq, Debug, Clone)]
 pub struct QueriesParams {

couch_rs/src/types/view.rs

@@ -1,5 +1,5 @@
 use crate::document::TypedCouchDocument;
-use serde::{de::DeserializeOwned, Deserialize, Serialize};
+use serde::{Deserialize, Serialize, de::DeserializeOwned};
 use serde_json::Value;
 use std::{collections::HashMap, string::ToString};