Dashboard › opencode › Distillation
c9c80f8a-1403-4aa8-98a5-f7a09a233292["lore_tm_v1_5PSjjE3TmwXlVFdeO4NdDHXZms9469HdgnG2g889jp0"]
Date: Sep 14, 2026
/home/byk/Code/opencode/packages/core/test/event.test.ts:323-352 defines test "ends only an overflowing bounded subscriber without blocking other listeners": creates slowStream via EventV2.allBounded(events, 1) and fastStream via EventV2.allBounded(events, 8); blocks the slow consumer using Deferred.make<void>(); publishes "one", "two", "overflow", and "still delivered"; expects only the slow fiber to fail with EventV2.SubscriberOverflowError; expects the fast subscriber to receive all 4 events in order, with the final item equal to the returned last event./home/byk/Code/opencode/packages/core/test/event.test.ts:354-371 defines test "preserves observer interruption": installs events.listen(() => Effect.interrupt), publishes SyncMessage with { id: "interrupted", text: "hello" }, verifies the publish exit has interrupts via Exit.isFailure(exit) && Cause.hasInterrupts(exit.cause), and verifies the durable EventTable row with aggregate_id="interrupted" was still committed./home/byk/Code/opencode/packages/core/test/event.test.ts:373-381 defines test "keeps live-only listener defects fail-fast": a listener executes Effect.die(defect) where defect = new Error("listener defect"); publishing Message with { text: "hello" } and catching the defect is expected to return the same defect object./home/byk/Code/opencode/packages/core/test/event.test.ts:383-401 defines test "inserts durable event rows on publish": creates aggregateID = EventV2.ID.create(), publishes SyncMessage with { id: aggregateID, text: "first" }, queries EventTable by aggregate_id, expects exactly 1 row, expects rows[0]?.type to equal EventV2.versionedType(SyncMessage.type, 1), and expects rows[0]?.aggregate_id to equal aggregateID./home/byk/Code/opencode/packages/core/test/event.test.ts:403-409 begins test "increments durable event seq per aggregate": obtains EventV2.Service and Database.Service, creates an aggregateID with EventV2.ID.create(), then publishes SyncMessage with { id: aggregateID, text: "first" }; the remainder of the test was not shown./home/byk/Code/opencode/packages/core/test/event.test.ts; continuation requires offset=410.