From 6eb237d49c551d4cae3e6b0b8da0488f045f70aa Mon Sep 17 00:00:00 2001 From: vkill Date: Thu, 19 Jan 2023 12:18:46 +0800 Subject: [PATCH 1/2] Remove unreachable --- async-ssh2-lite/src/session_stream/impl_tokio.rs | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/async-ssh2-lite/src/session_stream/impl_tokio.rs b/async-ssh2-lite/src/session_stream/impl_tokio.rs index 6812352..9126893 100644 --- a/async-ssh2-lite/src/session_stream/impl_tokio.rs +++ b/async-ssh2-lite/src/session_stream/impl_tokio.rs @@ -35,9 +35,7 @@ impl AsyncSessionStream for TcpStream { } match sess.block_directions() { - BlockDirections::None => { - unreachable!("") - } + BlockDirections::None => continue, BlockDirections::Inbound => { assert!(expected_block_directions.is_readable()); @@ -77,9 +75,7 @@ impl AsyncSessionStream for TcpStream { } match sess.block_directions() { - BlockDirections::None => { - unreachable!("") - } + BlockDirections::None => return Poll::Pending, BlockDirections::Inbound => { assert!(expected_block_directions.is_readable()); From f526c9c9ba9de94d6e8c783ceedadb423901f485 Mon Sep 17 00:00:00 2001 From: vkill Date: Thu, 19 Jan 2023 21:17:26 +0800 Subject: [PATCH 2/2] Remove unreachable --- async-ssh2-lite/src/session_stream/impl_async_io.rs | 8 ++------ async-ssh2-lite/src/session_stream/impl_tokio.rs | 8 ++------ 2 files changed, 4 insertions(+), 12 deletions(-) diff --git a/async-ssh2-lite/src/session_stream/impl_async_io.rs b/async-ssh2-lite/src/session_stream/impl_async_io.rs index 897b979..1e1b8bf 100644 --- a/async-ssh2-lite/src/session_stream/impl_async_io.rs +++ b/async-ssh2-lite/src/session_stream/impl_async_io.rs @@ -36,9 +36,7 @@ where } match sess.block_directions() { - BlockDirections::None => { - unreachable!("") - } + BlockDirections::None => continue, BlockDirections::Inbound => { assert!(expected_block_directions.is_readable()); @@ -80,9 +78,7 @@ where } match sess.block_directions() { - BlockDirections::None => { - unreachable!("") - } + BlockDirections::None => return Poll::Pending, BlockDirections::Inbound => { assert!(expected_block_directions.is_readable()); diff --git a/async-ssh2-lite/src/session_stream/impl_tokio.rs b/async-ssh2-lite/src/session_stream/impl_tokio.rs index 9126893..129c5d6 100644 --- a/async-ssh2-lite/src/session_stream/impl_tokio.rs +++ b/async-ssh2-lite/src/session_stream/impl_tokio.rs @@ -131,9 +131,7 @@ impl AsyncSessionStream for UnixStream { } match sess.block_directions() { - BlockDirections::None => { - unreachable!("") - } + BlockDirections::None => continue, BlockDirections::Inbound => { assert!(expected_block_directions.is_readable()); @@ -173,9 +171,7 @@ impl AsyncSessionStream for UnixStream { } match sess.block_directions() { - BlockDirections::None => { - unreachable!("") - } + BlockDirections::None => return Poll::Pending, BlockDirections::Inbound => { assert!(expected_block_directions.is_readable());