package oxbow

You can search for identifiers within the package.

in-package search v0.2.0

Module `Oxbow_runtime.Events`Source

Sourceval seed : Oxbow_state.Wm.t -> Oxbow_state.Wm.Ipc.Subscriber.t -> unit

seed wm sub fills sub's pending buffer with the last-published snapshots matching its filters and wakes its drain fiber.

Effects: mutates WM state

Sourceval publish : Oxbow_state.Wm.t -> unit

publish wm diffs current snapshots against the last-published set, updates matching subscribers with the changes, and records the new set.

Effects: mutates WM state