Merge pull request #33 from bk-rs/remove-unreachable

Remove unreachable

Author: vkill

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());
 

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());
 
@@ -135,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());
 
@@ -177,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());