○
Planned This feature is planned but not yet implemented.
Cascading auto-discharge: discharge creates new obligations that also need discharging
Failure Output
Showing last 10 of 23 lines
--> /Users/larsde/src/koru/tests/regression/300_ADVANCED_FEATURES/330_PHANTOM_TYPES/330_055_auto_discharge_cascade/db.kz:35:1
|
35 | ~[!]pub tor commit { tx: *Transaction<!in_transaction> }
| ^
error[PARSE003]: single continuation branch 'done' carrying a payload is a one-variant tag union — declare the single output as a bare return instead: `-> *Transaction`
--> /Users/larsde/src/koru/tests/regression/300_ADVANCED_FEATURES/330_PHANTOM_TYPES/330_055_auto_discharge_cascade/db.kz:54:1
|
54 | ~pub tor do-work { tx: *Transaction<in_transaction> }
| ^Code
~import app/db
const std = @import("std");
~app/db:connect(host: "localhost")
| connected _ |> app/db:begin(_.conn)
| begun _ |> app/db:do-work(_.tx)
pub fn main() void {
std.debug.print("Cascading auto-discharge test\n", .{});
}
Flows
flow ~connect click a branch to expand · @labels scroll to their anchor
connect (host: "localhost")
Imported Files
// Database module with cascading phantom obligations
//
// connect() → Connection<connected!>
// begin() → Transaction<in_transaction!> (consumes connected)
// commit() → Connection<connected!> (consumes in_transaction, CREATES connected!)
// close() → void (consumes connected)
const std = @import("std");
const Connection = struct { handle: i32 };
const Transaction = struct { conn: *Connection };
// connect: creates connection obligation
~pub tor connect { host: string }
| connected *Connection<connected!>
~proc connect|zig {
const c = std.heap.page_allocator.create(Connection) catch unreachable;
c.* = Connection{ .handle = 42 };
return .{ .connected = c };
}
// begin: consumes connection, creates transaction obligation
~pub tor begin { conn: *Connection<!connected> }
| begun *Transaction<in_transaction!>
~proc begin|zig {
const tx = std.heap.page_allocator.create(Transaction) catch unreachable;
tx.* = Transaction{ .conn = conn };
return .{ .begun = tx };
}
// commit: consumes transaction, CREATES connection obligation
// Marked [!] as default discharge for transactions
~[!]pub tor commit { tx: *Transaction<!in_transaction> }
| committed *Connection<connected!>
~proc commit|zig {
const c = tx.conn;
std.heap.page_allocator.destroy(tx);
return .{ .committed = c };
}
// close: consumes connection obligation, returns void
// Marked [!] as default discharge for connections
~pub tor close { conn: *Connection<!connected> }
~proc close|zig {
std.heap.page_allocator.destroy(conn);
return .closed;
}
// do-work: uses transaction without consuming it
~pub tor do-work { tx: *Transaction<in_transaction> }
| done *Transaction<in_transaction>
~proc do-work|zig {
std.debug.print("Working with transaction...\n", .{});
return .{ .done = tx };
}