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 6812352..129c5d6 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());
 
@@ -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());