chore: Use specific io error constructor

hyperium · Jan 11, 2025 · 54a41bf · 54a41bf
1 parent cbca447
commit 54a41bf
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 13 deletions.
diff --git a/examples/src/mock/mock.rs b/examples/src/mock/mock.rs
@@ -39,10 +39,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 if let Some(client) = client {
                     Ok(TokioIo::new(client))
                 } else {
-                    Err(std::io::Error::new(
-                        std::io::ErrorKind::Other,
-                        "Client already taken",
-                    ))
+                    Err(std::io::Error::other("Client already taken"))
                 }
             }
         }))

diff --git a/tests/integration_tests/tests/max_message_size.rs b/tests/integration_tests/tests/max_message_size.rs
@@ -166,10 +166,7 @@ async fn response_stream_limit() {
                 if let Some(client) = client {
                     Ok(TokioIo::new(client))
                 } else {
-                    Err(std::io::Error::new(
-                        std::io::ErrorKind::Other,
-                        "Client already taken",
-                    ))
+                    Err(std::io::Error::other("Client already taken"))
                 }
             }
         }))
@@ -335,10 +332,7 @@ async fn max_message_run(case: &TestCase) -> Result<(), Status> {
                 if let Some(client) = client {
                     Ok(TokioIo::new(client))
                 } else {
-                    Err(std::io::Error::new(
-                        std::io::ErrorKind::Other,
-                        "Client already taken",
-                    ))
+                    Err(std::io::Error::other("Client already taken"))
                 }
             }
         }))

diff --git a/tests/integration_tests/tests/status.rs b/tests/integration_tests/tests/status.rs
@@ -198,7 +198,7 @@ async fn status_from_server_stream_with_source() {
     let channel = Endpoint::try_from("http://[::]:50051")
         .unwrap()
         .connect_with_connector_lazy(tower::service_fn(move |_: Uri| async move {
-            Err::<TokioIo<MockStream>, _>(std::io::Error::new(std::io::ErrorKind::Other, "WTF"))
+            Err::<TokioIo<MockStream>, _>(std::io::Error::other("WTF"))
         }));
 
     let mut client = test_stream_client::TestStreamClient::new(channel);