fix frontend channel buffer size

This commit is contained in:
Ferdinand Schober
2024-01-16 16:03:33 +01:00
parent 0017dbc634
commit 347256e966
2 changed files with 7 additions and 2 deletions

View File

@@ -110,7 +110,7 @@ impl Server {
};
let (mut consumer, mut producer) = tokio::join!(consumer::create(), producer::create());
let (frontend_tx, mut frontend_rx) = tokio::sync::mpsc::channel(1);
let (frontend_tx, mut frontend_rx) = tokio::sync::mpsc::channel(32);
let (producer_notify_tx, mut producer_notify_rx) = tokio::sync::mpsc::channel(32);
let (consumer_notify_tx, mut consumer_notify_rx) = tokio::sync::mpsc::channel(32);
let (resolve_tx, mut resolve_rx) = tokio::sync::mpsc::channel(32);