File tree Expand file tree Collapse file tree 3 files changed +6
-16
lines changed Expand file tree Collapse file tree 3 files changed +6
-16
lines changed Original file line number Diff line number Diff line change @@ -661,7 +661,7 @@ impl Hosted {
661
661
662
662
impl FromIterator < String > for Hosted {
663
663
fn from_iter < I : IntoIterator < Item = String > > ( iter : I ) -> Self {
664
- Self ( iter. into_iter ( ) . map ( Into :: into ) . collect ( ) )
664
+ Self ( iter. into_iter ( ) . collect ( ) )
665
665
}
666
666
}
667
667
Original file line number Diff line number Diff line change @@ -137,18 +137,14 @@ impl<W: Write + Sync + Send + 'static> Writer for ConsoleWriter<W> {
137
137
138
138
self . write_fields ( & mut buf, values) ?;
139
139
140
- buf. write_all ( b"\n " )
141
- . map_err ( std:: io:: Error :: from)
142
- . context ( "new line" ) ?;
140
+ buf. write_all ( b"\n " ) . context ( "new line" ) ?;
143
141
144
142
match self . mu . lock ( ) {
145
143
Ok ( guard) => {
146
144
let mut w = guard
147
145
. try_borrow_mut ( )
148
146
. context ( "unable to borrow console output" ) ?;
149
- w. write_all ( & buf)
150
- . map_err ( std:: io:: Error :: from)
151
- . context ( "write" ) ?;
147
+ w. write_all ( & buf) . context ( "write" ) ?;
152
148
Ok ( ( ) )
153
149
}
154
150
Err ( poisoned) => Err ( anyhow:: anyhow!( "poisoned mutex: {:?}" , poisoned) ) ,
Original file line number Diff line number Diff line change @@ -80,16 +80,12 @@ impl<W: Write + Sync + Send + 'static> Writer for BlockingWriter<W> {
80
80
serde_json:: to_writer ( & mut buf, values)
81
81
. map_err ( std:: io:: Error :: from)
82
82
. context ( "serde_writer" ) ?;
83
- buf. write_all ( b"\n " )
84
- . map_err ( std:: io:: Error :: from)
85
- . context ( "new line" ) ?;
83
+ buf. write_all ( b"\n " ) . context ( "new line" ) ?;
86
84
87
85
match self . mu . lock ( ) {
88
86
Ok ( guard) => {
89
87
let mut w = guard. try_borrow_mut ( ) . context ( "unable to borrow" ) ?;
90
- w. write_all ( & buf)
91
- . map_err ( std:: io:: Error :: from)
92
- . context ( "write" ) ?;
88
+ w. write_all ( & buf) . context ( "write" ) ?;
93
89
Ok ( ( ) )
94
90
}
95
91
Err ( poisoned) => Err ( anyhow:: anyhow!( "poisoned mutex: {:?}" , poisoned) ) ,
@@ -121,9 +117,7 @@ impl<W: AsyncWrite + Sync + Send + 'static> Writer for AsyncWriter<W> {
121
117
serde_json:: to_writer ( & mut buf, values)
122
118
. map_err ( std:: io:: Error :: from)
123
119
. context ( "serde_writer" ) ?;
124
- buf. write_all ( b"\n " )
125
- . map_err ( std:: io:: Error :: from)
126
- . context ( "new line" ) ?;
120
+ buf. write_all ( b"\n " ) . context ( "new line" ) ?;
127
121
128
122
let mu = self . mu . clone ( ) ;
129
123
tokio:: spawn ( async move {
You can’t perform that action at this time.
0 commit comments