Struct SingleThreadedExecutor

pub struct SingleThreadedExecutor { /* private fields */ }

Single-threaded executor implementation.

Implementations

impl SingleThreadedExecutor

pub fn new() -> Self

Creates a new executor.

pub fn add_node(&self, node: &Arc<Node>) -> Result<(), RclrsError>

Add a node to the executor.

pub fn remove_node(&self, node: Arc<Node>) -> Result<(), RclrsError>

Remove a node from the executor.

pub fn spin_once(&self, timeout: Option<Duration>) -> Result<(), RclrsError>

Polls the nodes for new messages and executes the corresponding callbacks.

This function additionally checks that the context is still valid.

pub fn spin(&self) -> Result<(), RclrsError>

Convenience function for calling SingleThreadedExecutor::spin_once in a loop.

Trait Implementations

impl Default for SingleThreadedExecutor

fn default() -> Self

Returns the “default value” for a type.