astro/caveman
astro
/
caveman
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

smokestack/main: buffer more in Pipe channel

This commit is contained in:
Astro 2022-11-18 17:25:16 +01:00
parent a1e94843b4
commit f6ae6b42a2
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
smokestack/src/main.rs
View File

@ -119,7 +119,7 @@ impl State {
}
pub fn pipe(&self) -> Pipe {
let (tx, rx) = channel(1);
let (tx, rx) = channel(128);
let id = self.get_next_id();
let mut consumers = self.consumers.write().unwrap();