@@ -806,7 +806,6 @@ impl Drop for Async {
806806
807807// }}}
808808
809-
810809#[ cfg( test) ]
811810mod test {
812811 use super :: * ;
@@ -815,17 +814,22 @@ mod test {
815814 #[ test]
816815 fn integration_test ( ) {
817816 let ( mock_drain, mock_drain_rx) = MockDrain :: new ( ) ;
818- let async_drain = AsyncBuilder :: new ( mock_drain)
819- . build ( ) ;
820- let slog = slog:: Logger :: root ( async_drain. fuse ( ) , o ! ( "field1" => "value1" ) ) ;
817+ let async_drain = AsyncBuilder :: new ( mock_drain) . build ( ) ;
818+ let slog =
819+ slog:: Logger :: root ( async_drain. fuse ( ) , o ! ( "field1" => "value1" ) ) ;
821820
822821 info ! ( slog, "Message 1" ; "field2" => "value2" ) ;
823822 warn ! ( slog, "Message 2" ; "field3" => "value3" ) ;
824- assert_eq ! ( mock_drain_rx. recv( ) . unwrap( ) , r#"INFO Message 1: [("field1", "value1"), ("field2", "value2")]"# ) ;
825- assert_eq ! ( mock_drain_rx. recv( ) . unwrap( ) , r#"WARN Message 2: [("field1", "value1"), ("field3", "value3")]"# ) ;
823+ assert_eq ! (
824+ mock_drain_rx. recv( ) . unwrap( ) ,
825+ r#"INFO Message 1: [("field1", "value1"), ("field2", "value2")]"#
826+ ) ;
827+ assert_eq ! (
828+ mock_drain_rx. recv( ) . unwrap( ) ,
829+ r#"WARN Message 2: [("field1", "value1"), ("field3", "value3")]"#
830+ ) ;
826831 }
827832
828-
829833 /// Test-helper drain
830834 #[ derive( Debug ) ]
831835 struct MockDrain {
@@ -843,7 +847,11 @@ mod test {
843847 type Ok = ( ) ;
844848 type Err = slog:: Never ;
845849
846- fn log ( & self , record : & Record , logger_kv : & OwnedKVList ) -> Result < Self :: Ok , Self :: Err > {
850+ fn log (
851+ & self ,
852+ record : & Record ,
853+ logger_kv : & OwnedKVList ,
854+ ) -> Result < Self :: Ok , Self :: Err > {
847855 let mut serializer = MockSerializer :: default ( ) ;
848856 logger_kv. serialize ( record, & mut serializer) . unwrap ( ) ;
849857 record. kv ( ) . serialize ( record, & mut serializer) . unwrap ( ) ;
@@ -861,7 +869,11 @@ mod test {
861869 }
862870
863871 impl slog:: Serializer for MockSerializer {
864- fn emit_arguments ( & mut self , key : Key , val : & fmt:: Arguments ) -> Result < ( ) , slog:: Error > {
872+ fn emit_arguments (
873+ & mut self ,
874+ key : Key ,
875+ val : & fmt:: Arguments ,
876+ ) -> Result < ( ) , slog:: Error > {
865877 self . kvs . push ( ( key. to_string ( ) , val. to_string ( ) ) ) ;
866878 Ok ( ( ) )
867879 }
0 commit comments