factotum/nats.zig
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

examples: make request_reply slightly more interesting

Browse Source
This commit is contained in:
torque 2023-08-24 20:20:54 -07:00
parent 0dac8402cf
commit 226d678e68
Signed by: torque
SSH Key Fingerprint: SHA256:nCrXefBNo6EbjNSQhv0nXmEg/VuNq3sMF5b8zETw3Tk
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
examples/request_reply.zig
View File

@ -2,7 +2,7 @@ const std = @import("std");
const nats = @import("nats"); const nats = @import("nats");
fn onMessage( fn onMessage(
userdata: *bool, userdata: *u32,
connection: *nats.Connection, connection: *nats.Connection,
subscription: *nats.Subscription, subscription: *nats.Subscription,
message: *nats.Message, message: *nats.Message,
@ -18,18 +18,18 @@ fn onMessage(
connection.publish(reply, "salutations") catch @panic("HELP"); connection.publish(reply, "salutations") catch @panic("HELP");
} }
userdata.* = true; userdata.* += 1;
} }
pub fn main() !void { pub fn main() !void {
const connection = try nats.Connection.connectTo(nats.default_server_url); const connection = try nats.Connection.connectTo(nats.default_server_url);
defer connection.destroy(); defer connection.destroy();
var done = false; var count: u32 = 0;
const subscription = try connection.subscribe(bool, "channel", onMessage, &done); const subscription = try connection.subscribe(u32, "channel", onMessage, &count);
defer subscription.destroy(); defer subscription.destroy();
while (!done) { while (count < 10) : (nats.sleep(1000)) {
const reply = try connection.request("channel", "greetings", 1000); const reply = try connection.request("channel", "greetings", 1000);
defer reply.destroy(); defer reply.destroy();