Struct VibeEngineExecutor 

pub struct VibeEngineExecutor { /* private fields */ }

Task executor used internally by VibeEngine and exposed for advanced integrations. Executes futures and callbacks on the engine-owned runtime infrastructure.

Examples

use vibe_ready::{VibeEngine, VibeEngineConfig, VibeResult};

let engine = VibeEngine::create(VibeEngineConfig::builder().build())?;
let executor = engine.executor();
let value = executor.invoke(async { "ready" })?;
assert_eq!(value, "ready");

Implementations

impl VibeEngineExecutor

pub fn callback(&self) -> VibeCallbackExecutor

Returns the callback executor associated with this engine.

Returns

A cheap clone of VibeCallbackExecutor.

pub fn invoke<T, F>(&self, future: T) -> Result<F, VibeEngineError>

where T: Future<Output = F> + Send + 'static, F: Send + 'static,

Runs a future on the engine synchronous queue and waits for its output.

Returns

Ok(F) with the future output, or VibeEngineError if the task could not be queued or the runtime failed while waiting.

pub fn post<T>(&self, future: T) -> Result<(), VibeEngineError>

where T: Future<Output = ()> + Send + 'static,

Posts a fire-and-forget future to the engine asynchronous queue.

Returns

Ok(()) after the future is queued, or VibeEngineError if queuing fails.

Trait Implementations

impl Clone for VibeEngineExecutor

fn clone(&self) -> VibeEngineExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.