✗
Failing This test is currently failing.
Failed: output
Failure Output
🎯 Compiler coordination: Passes: 20 (flow-based: elaborate, analysis, emission)Code
// Test 170: Module-Level Event Globbing with Taps
//
// Tests that taps can use wildcards to match ALL events from a module.
// Pattern: ~input:* -> * matches ANY event in the main module.
//
// This demonstrates powerful observability - a single tap pattern can
// intercept every event in a module, perfect for profiling or logging.
//
// Structure:
// test_lib/
// logger.kz → Defines ~input:* -> * to intercept ALL main module events
//
// Expected: The logger's tap fires for ALL events (compute, format, display)
// even though the pattern only specifies ~input:* once.
const std = @import("std");
// Import the logger module (which defines module-level globbing tap)
~import app/test_lib/logger
// Define multiple events to test with
~tor compute { x: i32 } -> i32
~tor format { value: i32 } -> string
~tor display { text: string }
~proc compute|zig {
std.debug.print("compute({d})\n", .{x});
return x * 2;
}
~proc format|zig {
std.debug.print("format({d})\n", .{value});
const text = "formatted";
return text;
}
~proc display|zig {
std.debug.print("Final: {s}\n", .{text});
}
// Call all three events - the logger's ~input:* tap should intercept ALL of them!
~compute(x: 42): r |> format(value: r): f |> display(text: f)
Actual
[TAP] Intercepted: display
compute(42)
[TAP] Intercepted: display
format(84)
[TAP] Intercepted: display
Final: formatted
[TAP] Intercepted: display
[TAP] Intercepted: display
Expected output
[TAP] Intercepted: display
compute(42)
[TAP] Intercepted: compute
[TAP] Intercepted: display
format(84)
[TAP] Intercepted: format
[TAP] Intercepted: display
Final: formatted
[TAP] Intercepted: display
[TAP] Intercepted: display
Flows
flow ~compute click a branch to expand · @labels scroll to their anchor
compute (x: 42)
Imported Files
// Universal logger using module-level event globbing
// Demonstrates the power of wildcard patterns in taps
~import std/taps
const std = @import("std");
// Define a logging event
~pub tor log { event_name: string }
~proc log|zig {
std.debug.print("[TAP] Intercepted: {s}\n", .{event_name});
}
// Module-level glob: Intercept ALL events from main module
// This single pattern matches input:compute, input:format, input:display, etc.
// Perfect for module-wide profiling or logging!
// Tap for compute event (.result branch)
// Note: Tap flows must end with void - they're observers, not transformers
~tap(input:* -> *)
| result |> log(event_name: "compute")
// Tap for format event (.formatted branch)
~tap(input:* -> *)
| formatted |> log(event_name: "format")
// Tap for display event (.done branch)
~tap(input:* -> *)
| Profile _ |> log(event_name: "display")
Test Configuration
MUST_RUN