pub struct RillEngine { /* fields omitted */ }
Expand description
The supervisor that spawns a connector.
Creates a new supervisor instance.
Specifies how to group child actors.
Returns unique name of the Actor
.
Uses Uuid
by default. Read more
fn handle<'life0, 'life1, 'async_trait>(
&'life0 mut self,
ctx: &'life1 mut Context<Self>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Called when the Actor
terminated by another actor. Read more
fn handle<'life0, 'life1, 'async_trait>(
&'life0 mut self,
ctx: &'life1 mut Context<Self>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
It’s an initialization method of the Actor
.
impl<T> Any for T where
T: 'static + ?Sized,
Immutably borrows from an owned value. Read more
Mutably borrows from an owned value. Read more
pub fn handle<'life0, 'life1, 'async_trait>(
&'life0 mut self,
_input: Awake<S>,
ctx: &'life1 mut Context<T>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
Asyncronous method that receives incoming message.
pub fn handle<'life0, 'life1, 'async_trait>(
&'life0 mut self,
done: Done<C>,
ctx: &'life1 mut Context<T>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
Asyncronous method that receives incoming message.
pub fn handle<'life0, 'life1, 'async_trait>(
&'life0 mut self,
_input: Interrupt<S>,
ctx: &'life1 mut Context<T>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
T: 'async_trait,
Asyncronous method that receives incoming message.
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Instruments this type with the current Span
, returning an
Instrumented
wrapper. Read more
impl<T, U> Into<U> for T where
U: From<T>,
The type returned in the event of a conversion error.
The type returned in the event of a conversion error.
impl<V, T> VZip<V> for T where
V: MultiLane<T>,