semantic bufo search
find-bufo.com
bufo
remove noisy message counting log
-5
-5
bot/src/jetstream.zig
-5
bot/src/jetstream.zig
···
76
76
const Handler = struct {
77
77
allocator: Allocator,
78
78
callback: *const fn (Post) void,
79
-
msg_count: usize = 0,
80
79
81
80
pub fn serverMessage(self: *Handler, data: []const u8) !void {
82
-
self.msg_count += 1;
83
-
if (self.msg_count % 1000 == 1) {
84
-
std.debug.print("jetstream: processed {} messages\n", .{self.msg_count});
85
-
}
86
81
self.processMessage(data) catch |err| {
87
82
if (err != error.NotAPost) {
88
83
std.debug.print("message processing error: {}\n", .{err});