reformat code in doc comments using nightly rustfmt

Author: msrd0

benches/client.rs

@@ -1,7 +1,5 @@
 use chrono::{DateTime, Utc};
-use influxdb::Error;
-use influxdb::InfluxDbWriteable;
-use influxdb::{Client, ReadQuery};
+use influxdb::{Client, Error, InfluxDbWriteable, ReadQuery};
 use std::sync::Arc;
 use std::time::Instant;
 use tokio::sync::mpsc::unbounded_channel;

influxdb/src/client/mod.rs

@@ -22,8 +22,7 @@ use std::fmt::{self, Debug, Formatter};
 use std::sync::Arc;
 
 use crate::query::QueryType;
-use crate::Error;
-use crate::Query;
+use crate::{Error, Query};
 
 #[derive(Clone)]
 /// Internal Representation of a Client
@@ -188,17 +187,16 @@ impl Client {
     /// # Examples
     ///
     /// ```rust,no_run
-    /// use influxdb::{Client, Query, Timestamp};
-    /// use influxdb::InfluxDbWriteable;
+    /// use influxdb::{Client, InfluxDbWriteable, Query, Timestamp};
     /// use std::time::{SystemTime, UNIX_EPOCH};
     ///
     /// # #[tokio::main]
     /// # async fn main() -> Result<(), influxdb::Error> {
     /// let start = SystemTime::now();
     /// let since_the_epoch = start
-    ///   .duration_since(UNIX_EPOCH)
-    ///   .expect("Time went backwards")
-    ///   .as_millis();
+    ///     .duration_since(UNIX_EPOCH)
+    ///     .expect("Time went backwards")
+    ///     .as_millis();
     ///
     /// let client = Client::new("http://localhost:8086", "test");
     /// let query = Timestamp::Milliseconds(since_the_epoch)

influxdb/src/integrations/serde_integration/mod.rs

@@ -33,8 +33,7 @@
 //!     .series
 //!     .into_iter()
 //!     .map(|mut city_series| {
-//!         let city_name =
-//!             city_series.name.split("_").collect::<Vec<&str>>().remove(2);
+//!         let city_name = city_series.name.split("_").collect::<Vec<&str>>().remove(2);
 //!         Weather {
 //!             weather: city_series.values.remove(0),
 //!             city_name: city_name.to_string(),
@@ -50,7 +49,8 @@ mod de;
 use serde::de::DeserializeOwned;
 use serde_derive::Deserialize;
 
-use crate::{client::check_status, Client, Error, Query, ReadQuery};
+use crate::client::check_status;
+use crate::{Client, Error, Query, ReadQuery};
 
 #[derive(Deserialize)]
 #[doc(hidden)]

influxdb/src/lib.rs

@@ -16,7 +16,6 @@
 //! # Quickstart
 //!
 //! Add the following to your `Cargo.toml`
-//!
 #![doc = cargo_toml!(indent="", "derive")]
 //!
 //! For an example with using Serde deserialization, please refer to [serde_integration](crate::integrations::serde_integration)
@@ -45,13 +44,15 @@
 //!             humidity: 30,
 //!             wind_direction: String::from("north"),
 //!         }
-//!         .into_query("weather"),
+//!         .try_into_query("weather")
+//!         .unwrap(),
 //!         WeatherReading {
 //!             time: Timestamp::Hours(2).into(),
 //!             humidity: 40,
 //!             wind_direction: String::from("west"),
 //!         }
-//!         .into_query("weather"),
+//!         .try_into_query("weather")
+//!         .unwrap(),
 //!     ];
 //!
 //!     client.query(weather_readings).await?;
@@ -123,11 +124,9 @@ mod query;
 
 pub use client::Client;
 pub use error::Error;
-pub use query::{
-    read_query::ReadQuery,
-    write_query::{Type, WriteQuery},
-    InfluxDbWriteable, Query, QueryType, Timestamp, ValidQuery,
-};
+pub use query::read_query::ReadQuery;
+pub use query::write_query::{Type, WriteQuery};
+pub use query::{InfluxDbWriteable, Query, QueryType, Timestamp, ValidQuery};
 
 #[cfg(feature = "serde")]
 pub mod integrations {

influxdb/src/query/mod.rs

@@ -4,18 +4,17 @@
 //! # Examples
 //!
 //! ```rust
-//! use influxdb::{ReadQuery, Query as _, Timestamp};
-//! use influxdb::InfluxDbWriteable;
+//! use influxdb::{InfluxDbWriteable, Query as _, ReadQuery, Timestamp};
 //!
-//! let write_query = Timestamp::Nanoseconds(0).into_query("measurement")
+//! let write_query = Timestamp::Nanoseconds(0)
+//!     .into_query("measurement")
 //!     .add_field("field1", 5)
 //!     .add_tag("author", "Gero")
 //!     .build();
 //!
 //! assert!(write_query.is_ok());
 //!
-//! let read_query = ReadQuery::new("SELECT * FROM weather")
-//!     .build();
+//! let read_query = ReadQuery::new("SELECT * FROM weather").build();
 //!
 //! assert!(read_query.is_ok());
 //! ```
@@ -24,7 +23,8 @@ pub mod consts;
 mod line_proto_term;
 pub mod read_query;
 pub mod write_query;
-use std::{convert::Infallible, fmt};
+use std::convert::Infallible;
+use std::fmt;
 
 use crate::{Error, WriteQuery};
 use consts::{
@@ -130,13 +130,15 @@ pub trait Query {
     /// # Examples
     ///
     /// ```rust
-    /// use influxdb::{Query, Timestamp};
-    /// use influxdb::InfluxDbWriteable;
+    /// use influxdb::{InfluxDbWriteable, Query, Timestamp};
     ///
     /// let invalid_query = Timestamp::Nanoseconds(0).into_query("measurement").build();
     /// assert!(invalid_query.is_err());
     ///
-    /// let valid_query = Timestamp::Nanoseconds(0).into_query("measurement").add_field("myfield1", 11).build();
+    /// let valid_query = Timestamp::Nanoseconds(0)
+    ///     .into_query("measurement")
+    ///     .add_field("myfield1", 11)
+    ///     .build();
     /// assert!(valid_query.is_ok());
     /// ```
     fn build(&self) -> Result<ValidQuery, Error>;
@@ -148,15 +150,19 @@ pub trait Query {
     /// # Examples
     ///
     /// ```rust
-    /// use influxdb::{Query, Timestamp};
-    /// use influxdb::InfluxDbWriteable;
+    /// use influxdb::{InfluxDbWriteable, Query, Timestamp};
     ///
     /// let use_v2 = true;
     ///
-    /// let invalid_query = Timestamp::Nanoseconds(0).into_query("measurement").build_with_opts(use_v2);
+    /// let invalid_query = Timestamp::Nanoseconds(0)
+    ///     .into_query("measurement")
+    ///     .build_with_opts(use_v2);
     /// assert!(invalid_query.is_err());
     ///
-    /// let valid_query = Timestamp::Nanoseconds(0).into_query("measurement").add_field("myfield1", 11).build_with_opts(use_v2);
+    /// let valid_query = Timestamp::Nanoseconds(0)
+    ///     .into_query("measurement")
+    ///     .add_field("myfield1", 11)
+    ///     .build_with_opts(use_v2);
     /// assert!(valid_query.is_ok());
     /// ```
     fn build_with_opts(&self, use_v2: bool) -> Result<ValidQuery, Error>;

influxdb/src/query/write_query.rs

@@ -55,10 +55,12 @@ impl WriteQuery {
     /// # Examples
     ///
     /// ```rust
-    /// use influxdb::{Query, Timestamp};
-    /// use influxdb::InfluxDbWriteable;
+    /// use influxdb::{InfluxDbWriteable, Query, Timestamp};
     ///
-    /// Timestamp::Nanoseconds(0).into_query("measurement").add_field("field1", 5).build();
+    /// Timestamp::Nanoseconds(0)
+    ///     .into_query("measurement")
+    ///     .add_field("field1", 5)
+    ///     .build();
     /// ```
     #[must_use = "Creating a query is pointless unless you execute it"]
     pub fn add_field<S, F>(mut self, field: S, value: F) -> Self

influxdb/tests/integration_tests.rs

@@ -8,8 +8,7 @@ use utilities::{
     assert_result_err, assert_result_ok, create_client, create_db, delete_db, run_test,
 };
 
-use influxdb::InfluxDbWriteable;
-use influxdb::{Client, Error, ReadQuery, Timestamp};
+use influxdb::{Client, Error, InfluxDbWriteable, ReadQuery, Timestamp};
 
 /// INTEGRATION TEST
 ///

influxdb/tests/integration_tests_v2.rs

@@ -4,8 +4,7 @@ extern crate influxdb;
 mod utilities;
 use utilities::{assert_result_err, assert_result_ok, run_test};
 
-use influxdb::InfluxDbWriteable;
-use influxdb::{Client, Error, ReadQuery, Timestamp};
+use influxdb::{Client, Error, InfluxDbWriteable, ReadQuery, Timestamp};
 
 /// INTEGRATION TEST
 ///

influxdb_derive/src/writeable.rs

@@ -1,8 +1,8 @@
 use proc_macro2::{Span, TokenStream};
 use quote::{format_ident, quote};
+use syn::parse::{Parse, ParseStream};
+use syn::punctuated::Punctuated;
 use syn::{
-    parse::{Parse, ParseStream},
-    punctuated::Punctuated,
     AngleBracketedGenericArguments, Data, DeriveInput, Field, Fields, GenericArgument, Ident,
     Lifetime, Meta, PathArguments, PredicateType, Token, Type, TypeParamBound, WhereClause,
     WherePredicate,