Skip to content

Commit 4d22cc9

Browse files
am-kantoxwarp-agent
andcommitted
chore: bump version to 0.7.1
- Add send_info_after() to GenServerContext for scheduling info messages - Add whereis() to GenServerContext - Enhanced gen_server_self_message example with scheduled messaging Co-Authored-By: Warp <agent@warp.dev>
1 parent 64516e5 commit 4d22cc9

4 files changed

Lines changed: 6 additions & 9 deletions

File tree

Cargo.lock

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ members = ["joerl", "joerl_macro"]
33
resolver = "2"
44

55
[workspace.package]
6-
version = "0.7.0"
6+
version = "0.7.1"
77
edition = "2024"
88
authors = ["Aleksei Matiushkin <am@ambment.cat>"]
99
license = "MIT"

joerl/Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ async-trait = "0.1"
2020
dashmap = "6.1"
2121
parking_lot = "0.12"
2222
futures = "0.3"
23-
joerl_macro = { version = "0.7.0", path = "../joerl_macro" }
23+
joerl_macro = { version = "0.7.1", path = "../joerl_macro" }
2424
bincode = "1.3"
2525
serde = { version = "1.0", features = ["derive"] }
2626
once_cell = "1.20"

joerl/examples/gen_server_self_message.rs

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
//! - Work queues that process items sequentially
1212
1313
use async_trait::async_trait;
14-
use joerl::gen_server::{spawn, CallResponse, GenServer, GenServerContext, GenServerRef};
14+
use joerl::gen_server::{CallResponse, GenServer, GenServerContext, GenServerRef, spawn};
1515
use joerl::{ActorSystem, ExitReason, Message};
1616
use std::sync::Arc;
1717
use std::time::Duration;
@@ -145,10 +145,7 @@ impl GenServer for Ticker {
145145
TickerCall::Start => {
146146
println!("[Ticker] Starting periodic ticker");
147147
// Schedule first tick to ourselves after 100ms using send_info_after
148-
let timer_ref = ctx.send_info_after(
149-
Box::new("tick"),
150-
Duration::from_millis(100),
151-
);
148+
let timer_ref = ctx.send_info_after(Box::new("tick"), Duration::from_millis(100));
152149
println!("[Ticker] Scheduled timer: {:?}", timer_ref);
153150
CallResponse::Reply(state.0)
154151
}

0 commit comments

Comments
 (0)