11#![ allow( dead_code) ]
22
3+ extern crate itertools;
4+
35extern crate futures;
46extern crate reqwest;
57extern crate tokio;
68
79use futures:: Future ;
8- use reqwest:: r#async:: Client ;
910
11+ use itertools:: Itertools ;
12+ use reqwest:: r#async:: Client ;
1013trait InfluxDbQuery {
1114 fn build < ' a > ( self ) -> String ;
1215}
@@ -55,13 +58,11 @@ impl InfluxDbQuery for InfluxDbWrite {
5558 . tags
5659 . into_iter ( )
5760 . map ( |( tag, value) | format ! ( "{tag}={value}" , tag = tag, value = value) )
58- . collect :: < Vec < String > > ( )
5961 . join ( "," ) ;
6062 let fields = self
6163 . fields
6264 . into_iter ( )
6365 . map ( |( field, value) | format ! ( "{field}={value}" , field = field, value = value) )
64- . collect :: < Vec < String > > ( )
6566 . join ( "," ) ;
6667
6768 format ! (
@@ -136,9 +137,8 @@ mod tests {
136137
137138 #[ test]
138139 fn test_write_builder_single_field ( ) {
139- let query = InfluxDbQuery :: write ( )
140- . add_field ( "water_level" , "2" ) ;
141-
140+ let query = InfluxDbQuery :: write ( ) . add_field ( "water_level" , "2" ) ;
141+
142142 assert_eq ! ( query. build( ) , "measurement, water_level=2 time" ) ;
143143 }
144144
@@ -159,8 +159,7 @@ mod tests {
159159 // fixme: quoting / escaping of long strings
160160 #[ test]
161161 fn test_write_builder_single_tag ( ) {
162- let query = InfluxDbQuery :: write ( )
163- . add_tag ( "marina_manager" , "Smith" ) ;
162+ let query = InfluxDbQuery :: write ( ) . add_tag ( "marina_manager" , "Smith" ) ;
164163
165164 assert_eq ! ( query. build( ) , "measurement,marina_manager=Smith time" ) ;
166165 }
@@ -194,6 +193,9 @@ mod tests {
194193
195194 #[ test]
196195 fn test_test ( ) {
197- InfluxDbQuery :: write ( ) . add_field ( "test" , "1" ) . add_tag ( "my_tag" , "0.85" ) . build ( ) ;
196+ InfluxDbQuery :: write ( )
197+ . add_field ( "test" , "1" )
198+ . add_tag ( "my_tag" , "0.85" )
199+ . build ( ) ;
198200 }
199201}
0 commit comments