diff options
| -rw-r--r-- | src/stream.rs | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/stream.rs b/src/stream.rs index f5607b3..beb6b9c 100644 --- a/src/stream.rs +++ b/src/stream.rs @@ -200,7 +200,7 @@ fn u8_to_io_error(v: u8) -> std::io::Error { } fn io_error_to_u8(e: std::io::Error) -> u8 { - use std::io::{ErrorKind}; + use std::io::ErrorKind; match e.kind() { ErrorKind::ConnectionAborted => 101, ErrorKind::BrokenPipe => 102, @@ -217,8 +217,7 @@ fn io_error_to_u8(e: std::io::Error) -> u8 { } pub fn asyncread_stream<R: AsyncRead + Send + Sync + 'static>(reader: R) -> ByteStream { - Box::pin(tokio_util::io::ReaderStream::new(reader) - .map_err(io_error_to_u8)) + Box::pin(tokio_util::io::ReaderStream::new(reader).map_err(io_error_to_u8)) } pub fn stream_asyncread(stream: ByteStream) -> impl AsyncRead + Send + Sync + 'static { |