Struct InteractionHub 

pub struct InteractionHub { /* private fields */ }

A process-wide registry of open interactions, keyed by request id. Cheap to clone (shared Arc). Also a bevy Resource so the tick loop’s reflect_interaction_status system can mirror open requests into agent status.

Implementations

impl InteractionHub

pub fn new() -> Self

A fresh, empty hub.

pub fn attach_wake(&self, wake: Arc<Notify>)

Attach the tick-loop wake handle so registry changes wake the driver. Idempotent: a second call is ignored (the handle is set once at startup).

pub fn pending(&self) -> Vec<(String, InteractionRequest)>

Every open request, as (agent_id, request) pairs, for surfacing to clients.

pub fn answer(&self, response: InteractionResponse) -> bool

Answer an open request. Returns false if no request with that id is open (already answered, cancelled, or never existed).

pub fn cancel(&self, request_id: &str) -> bool

Cancel an open request (its submit returns the neutral response). Returns false if no such request is open.

pub fn cancel_for_agent(&self, agent_id: &str) -> usize

Cancel every open request belonging to agent_id, returning how many were closed. Each one’s submit wakes with the neutral response.

This is the per-agent counterpart of Self::cancel, which is keyed by request id - an id a canceller of a run doesn’t have. Without it, cancelling a run left its ask future blocked forever: the future holds a tool-lane worker (the lane has a fixed worker count, so enough of them stall every other agent’s tool batches), and the orphaned request keeps being surfaced by lev respond and the dashboard for a run that no longer exists.

pub fn backend_for(&self, agent_id: impl Into<String>) -> HubInteractionBackend

A per-agent InteractionBackend backed by this hub.

Trait Implementations

impl Clone for InteractionHub

fn clone(&self) -> InteractionHub

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Component for InteractionHub

where Self: Send + Sync + 'static,

const STORAGE_TYPE: StorageType = bevy_ecs::component::StorageType::SparseSet

A constant indicating the storage type used for this component.

type Mutability = Mutable

A marker type to assist Bevy with determining if this component is mutable, or immutable. Mutable components will have Component<Mutability = Mutable>, while immutable components will instead have Component<Mutability = Immutable>.

fn register_required_components( _requiree: ComponentId, required_components: &mut RequiredComponentsRegistrator<'_, '_>, )

Registers required components.

fn clone_behavior() -> ComponentCloneBehavior

Called when registering this component, allowing to override clone function (or disable cloning altogether) for this component.

fn relationship_accessor() -> Option<ComponentRelationshipAccessor<Self>>

Returns ComponentRelationshipAccessor required for working with relationships in dynamic contexts.

fn on_add() -> Option<for<'w> fn(DeferredWorld<'w>, HookContext)>

Gets the on_add ComponentHook for this Component if one is defined.

fn on_insert() -> Option<for<'w> fn(DeferredWorld<'w>, HookContext)>

Gets the on_insert ComponentHook for this Component if one is defined.

fn on_discard() -> Option<for<'w> fn(DeferredWorld<'w>, HookContext)>

Gets the on_discard ComponentHook for this Component if one is defined.

fn on_remove() -> Option<for<'w> fn(DeferredWorld<'w>, HookContext)>

Gets the on_remove ComponentHook for this Component if one is defined.

fn on_despawn() -> Option<for<'w> fn(DeferredWorld<'w>, HookContext)>

Gets the on_despawn ComponentHook for this Component if one is defined.

fn map_entities<E>(_this: &mut Self, _mapper: &mut E)

where E: EntityMapper,

Maps the entities on this component using the given EntityMapper. This is used to remap entities in contexts like scenes and entity cloning. When deriving Component, this is populated by annotating fields containing entities with #[entities]

impl Default for InteractionHub

fn default() -> InteractionHub

Returns the “default value” for a type.

impl Resource for InteractionHub

where Self: Send + Sync + 'static,