From 4d371b55c128d2eeef26c084e13b0a80f065847a Mon Sep 17 00:00:00 2001
From: Sachymetsu <sachymetsu@tutamail.com>
Date: Tue, 21 Jul 2026 09:33:41 +0200
Subject: [PATCH] Stack tweaks

---
 src/main.rs | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index ef8df06..40964a0 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -1,11 +1,15 @@
-use std::time::Duration;
+mod scan;
+
+use std::{sync::Arc, time::Duration};
 
 use bluer::l2cap::{Socket, SocketAddr};
-use ergot::toolkits::tokio_stream::{self, EdgeStack, register_controller_stream};
+use ergot::{
+    exports::bbqueue::{BBQueue, traits::storage::BoxedSlice},
+    interface_manager::utils::std::StdQueue,
+    toolkits::tokio_stream::{self, EdgeStack, register_controller_stream},
+};
 use water_pod_common::SyncEndpoint;
 
-mod scan;
-
 const SPSM_L2CAP_WATER: u16 = 0x0089;
 
 const MAX_ERGOT_PACKET_SIZE: u16 = 2048;
@@ -37,7 +41,8 @@ async fn endpoint_server(stack: &EdgeStack) {
 async fn main() -> Result<(), std::io::Error> {
     env_logger::init();
 
-    let stack_queue = tokio_stream::new_std_queue(TX_BUFFER_SIZE);
+    let stack_queue: StdQueue =
+        Arc::new(BBQueue::new_with_storage(BoxedSlice::new(TX_BUFFER_SIZE)));
     let stack = tokio_stream::new_controller_stack(&stack_queue, MAX_ERGOT_PACKET_SIZE);
 
     log::info!("Starting session");
-- 
2.51.2