Changes
1 changed files (+2/-8)
-
-
@@ -332,19 +332,13 @@ Event.exportEventCastFunction(transport.ZoneListEvent, .zone_list);} }; inline fn timedWaitMs(reset_event: *std.Thread.ResetEvent, timeout_ms: usize) error{Timeout}!void { // 1 milliseconds = 1,000 microseconds // 1 microseconds = 1,000 nanoseconds try reset_event.timedWait(timeout_ms * 1000 * 1000); } fn Listener(comptime T: type, timeout_ms: usize) type { return struct { wrote: std.Thread.ResetEvent = .{}, data: ?T = null, pub fn listen(self: *@This()) error{Timeout}!T { try timedWaitMs(&self.wrote, timeout_ms); try self.wrote.timedWait(timeout_ms * std.time.ns_per_ms); return self.data orelse @panic("Set Listener.wrote before writing data"); }
-
@@ -382,7 +376,7 @@ return .{ .hash = ImageDownload.getHash(image_key, opts) };} pub fn getDownloaded(self: *@This()) error{Timeout}!*image.GetResult { try timedWaitMs(&self.ready, 5_000); try self.ready.timedWait(5_000 * std.time.ns_per_ms); return self.downloaded; }
-