Struct PartialOrderingHook 

pub struct PartialOrderingHook<K, V, B: Boundedness = Unbounded> { /* private fields */ }

A hook handle controlling an entries_partially_ordered operator over a keyed stream with keys K and values V.

The operator preserves the order of values within each key while interleaving across keys non-deterministically. A top-level decision releases the front entry of one key’s buffer; inside a tick, a single decision supplies the complete interleaving. See hydro_lang::sim::hooks for the decisions offered.

Implementations

impl<K, V> PartialOrderingHook<K, V, Unbounded>

where K: Serialize + DeserializeOwned, V: Serialize + DeserializeOwned,

pub fn next(&self, key: K, value: V) -> DecisionFuture

Available on crate feature sim only.

Scripts a top-level entries_partially_ordered action to release the front entry of key’s buffer, which must equal value (within-key order is preserved, so a mismatch panics). Exactly one entry is released, preserving opportunities for ticks and feedback to interleave with the remaining buffered input.

pub fn pause(&self)

Available on crate feature sim only.

Declares that buffering at this operator is intended: while paused, the hook is exempt from the missing-decision error, never causes its tick to run, and — if its tick runs anyway because other hooks feed it — contributes its “nothing new” behavior each time. Scripting any decision implicitly resumes the hook.

A pause takes its place in the script like everything else: requested while a decision is still pending, the hold begins once that decision has been consumed.

pub fn resume(&self)

Available on crate feature sim only.

Ends a Self::pause (and clears Self::auto_pause mode).

pub fn auto_pause(&self)

Available on crate feature sim only.

Sets a standing mode where this hook only ever acts when scripted: it holds immediately, and every scripted decision leaves a fresh hold in place behind it.

This deliberately opts out of the forgotten-hook protection: if the test forgets a step, the operator silently holds its data instead of failing. The one auto_pause() line at the top of a test is the reviewer-visible marker that this hook’s timing is entirely script-driven, missed steps and all.

pub async fn pause_while<Fut: Future>(&self, body: Fut) -> Fut::Output

Available on crate feature sim only.

Pauses the hook exactly for the duration of body (resuming even on panic), so a bracketed buffering phase cannot leak a paused hook.

pub fn pause_until( &self, predicate: impl Fn(&OrderingStatus) -> bool + Unpin, ) -> PauseUntilFuture<OrderingStatus, impl Fn(&OrderingStatus) -> bool + Unpin>

Available on crate feature sim only.

Pauses the hook and returns a future that resolves once the hook’s pending-input status satisfies predicate — a synchronization point for scripts where the right decision is not knowable upfront. The status is read on demand at every scheduling point. After the future resolves, the hook is unpaused; the ordinary missing-decision error applies from there on.

pub fn pause_until_count( &self, n: usize, ) -> PauseUntilFuture<OrderingStatus, impl Fn(&OrderingStatus) -> bool + Unpin>

Available on crate feature sim only.

Pauses a top-level partially-ordered hook until at least n entries are buffered (in total, across all keys); see Self::pause_until.

impl<K, V> PartialOrderingHook<K, V, Bounded>

where K: Serialize + DeserializeOwned, V: Serialize + DeserializeOwned,

pub fn order(&self, entries: impl IntoIterator<Item = (K, V)>) -> DecisionFuture

Available on crate feature sim only.

Scripts an in-tick entries_partially_ordered observation to consume its complete input in exactly this interleaving. The supplied entries must be a permutation of all (key, value) entries received by the operator during that tick that preserves each key’s within-key order.

Trait Implementations

impl<K, V, B: Boundedness> Clone for PartialOrderingHook<K, V, B>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<K, V, B: Boundedness> Copy for PartialOrderingHook<K, V, B>

impl<K, V, B: Boundedness> Debug for PartialOrderingHook<K, V, B>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<K, V, B: Boundedness> SimHook for PartialOrderingHook<K, V, B>

where K: Hash + Eq + Clone + Serialize + DeserializeOwned, V: Serialize + DeserializeOwned + PartialEq,

fn create(next_id: &mut dyn FnMut() -> usize) -> Self

Creates every handle in this value, allocating fresh IDs via next_id.