diff --git a/std/event.zig b/std/event.zig index f3913a432b315b2619764a67c1eb7e3ddaf6fbe2..1e520862863a51160970ee37aa230f3968191509 100644 --- a/std/event.zig +++ b/std/event.zig @@ -4,7 +4,7 @@ pub const Lock = @import("event/lock.zig").Lock; pub const tcp = @import("event/tcp.zig"); pub const Channel = @import("event/channel.zig").Channel; pub const Group = @import("event/group.zig").Group; -pub const Future = @import("event/future.zig").Group; +pub const Future = @import("event/future.zig").Future; test "import event tests" { _ = @import("event/locked.zig"); diff --git a/std/event/future.zig b/std/event/future.zig index 6c0364182878c01ef7eee6122a9dc575e28a1870..b6ec861f77b5c8e7a463b2bde0326edc4cc9cf34 100644 --- a/std/event/future.zig +++ b/std/event/future.zig @@ -67,6 +67,9 @@ test "std.event.Future" { } async fn testFuture(loop: *Loop) void { + suspend |p| { + resume p; + } var future = Future(i32).init(loop); const a = async waitOnFuture(&future) catch @panic("memory"); @@ -79,10 +82,16 @@ async fn testFuture(loop: *Loop) void { } async fn waitOnFuture(future: *Future(i32)) i32 { + suspend |p| { + resume p; + } return (await (async future.get() catch @panic("memory"))).*; } async fn resolveFuture(future: *Future(i32)) void { + suspend |p| { + resume p; + } future.data = 6; future.resolve(); }