Non-blocking destructive bus
- Dominant language
- Rust
- Stars
- 846
- Forks
- 43
- PR merge metrics
- No merged PRs in 30d
Description
Hi!
I have a need for a non-blocking sender. When the bus is full, I'd like to overwrite oldest non-read elements (so readers might skip items if they're too slow) rather than blocking. `Bus::try_broadcast` is not working for me since I still need to send the new message when the bus is full.
Is it something this library might add?
Contributor guide
No contributing guide indexed for this repository
Research direction
Start by reading the existing Bus::try_broadcast behavior and the surrounding broadcast-channel API. Determine how a non-blocking destructive sender should interact with full buses and slow readers. Done means the requested behavior is defined and implemented with coverage for full and partially read buses.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- rust
- Domain
- distributed-systems
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 30/100