Skip to content

Implement basic combinators map, filter and filter_map for irpc channels. #68

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 14 commits into from
Oct 8, 2025
Merged

Implement basic combinators map, filter and filter_map for irpc channels. #68

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
ea018f9
Some initial renaming
rklaehn Oct 6, 2025
2b62879
Implement with_map, with_filter_map and with_filter for mpsc::Sender …
rklaehn Oct 6, 2025
4a25342
Relax trait constraints.
rklaehn Oct 6, 2025
251ed2d
Make Clone less restritive
rklaehn Oct 6, 2025
8601e36
Restrict trait constraints to make it possible to call send for non-S…
rklaehn Oct 6, 2025
296ba01
Remove SendFut
rklaehn Oct 6, 2025
d1556e3
Undo wrong rename, but call tokio local, since it is no longer just t…
rklaehn Oct 6, 2025
43d5c7c
reduce constraints even more
rklaehn Oct 6, 2025
0b1fe9e
Allow creating a local client from an irpc channel of messages that c…
rklaehn Oct 6, 2025
d15f8e2
Change compute example to use a crate mpsc receiver.
rklaehn Oct 6, 2025
422ee0d
further reduce bounds, also comments
rklaehn Oct 6, 2025
9099332
Add transform tests
rklaehn Oct 7, 2025
683fa7c
Reduce some more bounds.
rklaehn Oct 8, 2025
3dd027e
PR review - DRY bounds
rklaehn Oct 8, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions examples/compute.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -55,12 +55,12 @@ struct Multiply {

// The actor that processes requests
struct ComputeActor {
recv: tokio::sync::mpsc::Receiver<ComputeMessage>,
recv: irpc::channel::mpsc::Receiver<ComputeMessage>,
}

impl ComputeActor {
pub fn local() -> ComputeApi {
let (tx, rx) = tokio::sync::mpsc::channel(128);
let (tx, rx) = irpc::channel::mpsc::channel(128);
let actor = Self { recv: rx };
n0_future::task::spawn(actor.run());
ComputeApi {
Expand All @@ -69,7 +69,7 @@ impl ComputeActor {
}

async fn run(mut self) {
while let Some(msg) = self.recv.recv().await {
while let Ok(Some(msg)) = self.recv.recv().await {
n0_future::task::spawn(async move {
if let Err(cause) = Self::handle(msg).await {
eprintln!("Error: {cause}");
Expand Down
Loading