Struct ExecutorController 

pub struct ExecutorController { /* private fields */ }

Controls background handler dispatch tasks started by Photon::start_executor.

Implementations

impl ExecutorController

pub fn start( &self, photon: &Photon, identity: &Arc<dyn IdentityFactory>, ) -> Result<()>

Spawn subscription loops for every inventory-registered handler.

Panics

Panics if an internal lock is poisoned.

Errors

Returns an error if the executor was already started on this controller.

Contract

• Start is one-shot per controller; restart requires a new Photon build.
• Outer loops respect Self::shutdown; in-flight handler tasks are awaited in Self::join.

pub fn shutdown(&self)

Signal all handler loops to stop accepting new events.

Contract

• Idempotent: repeated calls are no-ops.
• Does not wait for in-flight handlers; call Self::join afterward.

pub async fn join(&self)

Await outer subscription loops (and their in-flight handler tasks).

Contract

• Call Self::shutdown first for prompt exit from stream loops.
• Drains stored outer JoinHandles; each loop drains its own in-flight JoinSet before exiting.
• Safe to call when no tasks were started (no-op).

Panics

Panics if an internal lock is poisoned.

Trait Implementations

impl Default for ExecutorController

fn default() -> Self

Returns the “default value” for a type.