Struct TurnSteering 

pub struct TurnSteering { /* private fields */ }

Concurrency-safe ingress for messages sent while an in-process turn runs.

Closing and observing an empty queue is one atomic operation. A sender can therefore never be told that it steered a turn after that turn committed to completion; rejected input belongs to the next turn instead.

This type, AcceptedTurnInput, TurnSteeringPushError, InProcessRuntime::run_steerable_turn and InProcessRuntime::append_accepted_inputs form the steering surface the separately published everruns facade drives. It was #[doc(hidden)] while that was treated as internal plumbing, which is what let a signature change ship under a host patch release and break the published facade (everruns/yolop#665) – #[doc(hidden)] hides an item from rustdoc and from cargo-semver-checks, but it does not make it private, and a contract crossing a crates.io boundary is public whatever it is annotated with. Change these together with a host minor bump and a facade release.

Implementations

impl TurnSteering

pub fn new() -> Self

pub fn try_push( &self, input: AcceptedTurnInput, ) -> Result<(), TurnSteeringPushError>

pub fn close(&self)

pub fn close_and_drain(&self) -> Vec<AcceptedTurnInput>

Trait Implementations

impl Clone for TurnSteering

fn clone(&self) -> TurnSteering

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TurnSteering

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

Formats the value using the given formatter.

impl Default for TurnSteering

fn default() -> Self

Returns the “default value” for a type.