diff --git a/testcontainers/src/core/logs.rs b/testcontainers/src/core/logs.rs
index d249a4ec..d47f4f3d 100644
--- a/testcontainers/src/core/logs.rs
+++ b/testcontainers/src/core/logs.rs
@@ -135,7 +135,7 @@ impl fmt::Debug for WaitingStreamWrapper {
 mod tests {
     use super::*;
 
-    #[tokio::test(flavor = "multi_thread")]
+    #[tokio::test]
     async fn given_logs_when_line_contains_message_should_find_it() {
         let _ = pretty_env_logger::try_init();
         let log_stream = || {
diff --git a/testcontainers/src/core/wait/mod.rs b/testcontainers/src/core/wait/mod.rs
index be233235..77eb5c00 100644
--- a/testcontainers/src/core/wait/mod.rs
+++ b/testcontainers/src/core/wait/mod.rs
@@ -49,7 +49,7 @@ impl WaitFor {
 
     /// Wait for the message to appear on the container's stderr.
     pub fn message_on_stderr(message: impl AsRef<[u8]>) -> WaitFor {
-        Self::log(LogWaitStrategy::new(LogSource::StdOut, message))
+        Self::log(LogWaitStrategy::new(LogSource::StdErr, message))
     }
 
     /// Wait for the message to appear on the container's stdout.
diff --git a/testcontainers/tests/async_runner.rs b/testcontainers/tests/async_runner.rs
index d221e0ad..59d8f4a3 100644
--- a/testcontainers/tests/async_runner.rs
+++ b/testcontainers/tests/async_runner.rs
@@ -101,6 +101,7 @@ async fn async_run_exec() -> anyhow::Result<()> {
     let _ = pretty_env_logger::try_init();
 
     let image = GenericImage::new("simple_web_server", "latest")
+        .with_wait_for(WaitFor::message_on_stderr("server will be listening to"))
         .with_wait_for(WaitFor::log(
             LogWaitStrategy::stdout("server is ready").with_times(2),
         ))
diff --git a/testimages/src/bin/simple_web_server.rs b/testimages/src/bin/simple_web_server.rs
index 7127e6c2..afd2e08c 100644
--- a/testimages/src/bin/simple_web_server.rs
+++ b/testimages/src/bin/simple_web_server.rs
@@ -12,6 +12,7 @@ async fn main() {
     // run it
     let addr = SocketAddr::from(([0, 0, 0, 0], 80));
     let listener = tokio::net::TcpListener::bind(addr).await.unwrap();
+    eprintln!("server will be listening to the port 80");
     println!("server is ready");
     println!("server is ready"); // duplicate line to test `times` parameter of `WaitFor::Log`
     axum::serve(listener, app.into_make_service())