From b93ca8494aa7fabfab22583cb0e23b5e5d9e905e Mon Sep 17 00:00:00 2001
From: OlivierHecart <olivier@zettascale.tech>
Date: Wed, 3 Jul 2024 14:37:27 +0200
Subject: [PATCH] REST plugin uses unbounded flume channels for queries (#1213)

---
 plugins/zenoh-plugin-rest/src/lib.rs | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/plugins/zenoh-plugin-rest/src/lib.rs b/plugins/zenoh-plugin-rest/src/lib.rs
index fa5c3c6ac3..f683e3992a 100644
--- a/plugins/zenoh-plugin-rest/src/lib.rs
+++ b/plugins/zenoh-plugin-rest/src/lib.rs
@@ -380,7 +380,12 @@ async fn query(mut req: Request<(Arc<Session>, String)>) -> tide::Result<Respons
             QueryConsolidation::from(zenoh::query::ConsolidationMode::Latest)
         };
         let raw = selector.decode().any(|(k, _)| k.as_ref() == RAW_KEY);
-        let mut query = req.state().0.get(&selector).consolidation(consolidation);
+        let mut query = req
+            .state()
+            .0
+            .get(&selector)
+            .with(flume::unbounded())
+            .consolidation(consolidation);
         if !body.is_empty() {
             let encoding: Encoding = req
                 .content_type()