Struct ReactorSpawner

pub struct ReactorSpawner<R, CODEC = Bincode>
where
    R: Reactor + 'static,
    CODEC: Codec,
{ /* private fields */ }

A spawner to create oneshot workers.

Implementations

impl<R, CODEC> ReactorSpawner<R, CODEC>

where R: Reactor + 'static, CODEC: Codec,

pub const fn new() -> ReactorSpawner<R, CODEC>

Creates a ReactorSpawner.

pub const fn encoding<C>(&self) -> ReactorSpawner<R, C>

where C: Codec,

Sets a new message encoding.

pub fn spawn(self, path: &str) -> ReactorBridge<R>

where <<R as Reactor>::Scope as ReactorScoped>::Input: Serialize + for<'de> Deserialize<'de>, <<R as Reactor>::Scope as ReactorScoped>::Output: Serialize + for<'de> Deserialize<'de>,

Spawns a reactor worker.

pub fn spawn_with_loader(self, loader_path: &str) -> ReactorBridge<R>

where <<R as Reactor>::Scope as ReactorScoped>::Input: Serialize + for<'de> Deserialize<'de>, <<R as Reactor>::Scope as ReactorScoped>::Output: Serialize + for<'de> Deserialize<'de>,

Spawns a Reactor Worker with a loader shim script.

Trait Implementations

impl<R, CODEC> Debug for ReactorSpawner<R, CODEC>

where R: Debug + Reactor + 'static, CODEC: Debug + Codec,

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

Formats the value using the given formatter.

impl<R, CODEC> Default for ReactorSpawner<R, CODEC>

where R: Default + Reactor + 'static, CODEC: Default + Codec,

fn default() -> ReactorSpawner<R, CODEC>

Returns the “default value” for a type.