fix(channel): ready check

Curve · Oct 11, 2023 · b88615a · b88615a
1 parent 5dd02e7
commit b88615a
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/channel.cpp b/src/channel.cpp
@@ -2,6 +2,7 @@
 #include "channel/channel.hpp"
 
 #include <future>
+#include <chrono>
 #include <cstdint>
 #include <pipewire/pipewire.h>
 
@@ -29,6 +30,13 @@ namespace pipewire
             return;
         }
 
+        auto status = m_impl->source.wait_for(std::chrono::seconds(0));
+
+        if (status != std::future_status::ready)
+        {
+            return;
+        }
+
         auto *source = m_impl->source.get();
 
         if (source->fd < 0)