jonhoo / jonhoo/bus

Non-blocking destructive bus

Open
#21 3 comments 0 reactions 0 assignees View on GitHub
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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.