use std/io use std/vec.Vec struct Counter { value: i32 } blocking func main(): i32! { var counters = Vec [Counter { value: 1 }, Counter { value: 2 }, Counter { value: 3 }] for counter in &+counters { counter.value += 10 } var borrowed_total: i32 = 0 for counter in &counters { borrowed_total += counter.value } var moved_total: i32 = 0 for counter in move counters { moved_total += counter.value } let message = "borrowed: ${borrowed_total}, moved: ${moved_total}\n" io.print(&message)? return 0 }

func main(): i32 { let value = load_value() catch failure { fallback_for(failure.message()) } if value == 42 { return 0 } return 1 } func load_value(): i32! { return error.new("example.unavailable", "the primary value is unavailable") } func fallback_for(message: &str): i32 { return 42 }

use std/task use std/time use std/time.Duration async func delayed(value: i32): i32 { await time.sleep(Duration.from_milliseconds(1)) return value } async func main(): i32! { let (left, right) = await task.join(delayed(20), delayed(22)) if left + right != 42 { return error.new("example.unexpected_total", "joined tasks returned the wrong total") } return 0 }

use std/io use std/url.Url blocking func main(): i32! { let url = Url.parse("HTTP://Example.COM:80/a/../status?q=ready#fragment")? let canonical = url.to_string() let authority = url.authority() let target = url.request_target() io.println(&canonical)? io.println(&authority)? io.println(&target)? return 0 }

nocter-darwin-reactor

Responsibility

Implement and exercise the Darwin readiness boundary accepted by nocter-task-runtime without owning task lifecycle or computation frames.

Contract

The adapter projects generation-qualified logical registrations onto kqueue-backed descriptor and process-exit events plus one monotonic timer domain. More than one logical registration may observe one native descriptor direction or process. Native tokens are never reused, so a queued event cannot acquire the meaning of a replacement native subject.

This host implementation closes and tests native event semantics. Generated Nocter executables do not link this Rust crate; ARM64 runtime generation must implement the same Reactor contract and is qualified independently before v0.41.0 closes.

Invariants

Registering a logical interest either completes fully or retains no registration.
Removing a registration invalidates its logical and native-token mapping before returning.
Cancelling the last logical waiter releases only its registration; the reactor never closes or duplicates the observed descriptor, which may be registered again by its owner.
Native deregistration failure can leave only harmless surplus observation; opaque-token and filter validation prevent it from reaching a current logical registration.
Read closure and descriptor errors wake readable waiters; write closure and descriptor errors wake writable waiters so operation code can observe the actual result.
Process completion is readiness only; status collection and process ownership remain outside the reactor.
Timer deadlines are fixed observations in the adapter clock domain and never restart after an interrupted or spurious native wait.

nocter-darwin-reactor#

Responsibility#

Contract#

Invariants#

nocter-darwin-reactor

Responsibility

Contract

Invariants