Struct ReactorRegistrar

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

A registrar for reactor workers.

Implementations

impl<R, CODEC> ReactorRegistrar<R, CODEC>

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

pub fn new() -> Self

Creates a new reactor registrar.

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

where C: Codec + 'static,

Sets the encoding.

pub fn register(&self)

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

Registers the worker.

Trait Implementations

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

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

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

Formats the value using the given formatter.

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

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

fn default() -> Self

Returns the “default value” for a type.