diff --git a/include/async/queue.hpp b/include/async/queue.hpp
index cd8e35d..5fd0929 100644
--- a/include/async/queue.hpp
+++ b/include/async/queue.hpp
@@ -140,6 +140,10 @@ struct queue {
 		return {this, ct};
 	}
 
+	bool empty() {
+		return buffer_.empty();
+	}
+
 	frg::optional<T> maybe_get() {
 		frg::unique_lock lock{mutex_};