atscan.net / plcbundle-rs
High-performance implementation of plcbundle written in Rust
fork atom

fix(plc_client): handle semaphore acquisition failure explicitly

tree.fail df621652 0a208305

build.yml
+2 -3
+2 -3
src/plc_client.rs
··· 335 335 } 336 336 337 337 async fn wait(&self) { 338 - // Wait for a permit to become available 339 - // This will block until a permit is available (from refill task) 340 - let _ = self.semaphore.acquire().await; 338 + let permit = self.semaphore.acquire().await.expect("semaphore closed"); 339 + permit.forget(); 341 340 } 342 341 343 342 fn available_permits(&self) -> usize {