[−][src]Struct tempest::topology::SourceActor
Trait Implementations
impl Default for SourceActor
[src]
impl Actor for SourceActor
[src]
type Context = Context<Self>
Actor execution context type
fn started(&mut self, ctx: &mut Context<Self>)
[src]
fn stopping(&mut self, ctx: &mut Self::Context) -> Running
[src]
Called after an actor is in Actor::Stopping
state. Read more
fn stopped(&mut self, ctx: &mut Self::Context)
[src]
Called after an actor is stopped. Read more
fn start(self) -> Addr<Self> where
Self: Actor<Context = Context<Self>>,
[src]
Self: Actor<Context = Context<Self>>,
Start a new asynchronous actor, returning its address. Read more
fn start_default() -> Addr<Self> where
Self: Actor<Context = Context<Self>> + Default,
[src]
Self: Actor<Context = Context<Self>> + Default,
Construct and start a new asynchronous actor, returning its address. Read more
fn start_in_arbiter<F>(arb: &Arbiter, f: F) -> Addr<Self> where
F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,
Self: Actor<Context = Context<Self>>,
[src]
F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,
Self: Actor<Context = Context<Self>>,
Start new actor in arbiter's thread.
fn create<F>(f: F) -> Addr<Self> where
F: FnOnce(&mut Context<Self>) -> Self + 'static,
Self: Actor<Context = Context<Self>>,
[src]
F: FnOnce(&mut Context<Self>) -> Self + 'static,
Self: Actor<Context = Context<Self>>,
Start a new asynchronous actor given a Context
. Read more
impl Supervised for SourceActor
[src]
fn restarting(&mut self, ctx: &mut Self::Context)
[src]
Called when the supervisor restarts a failed actor.
impl Handler<SourceAckMsg> for SourceActor
[src]
type Result = ()
The type of value that this handler will return.
fn handle(&mut self, msg: SourceAckMsg, _ctx: &mut Context<Self>)
[src]
impl Handler<Flush> for SourceActor
[src]
type Result = ()
The type of value that this handler will return.
fn handle(&mut self, _msg: Flush, _ctx: &mut Context<Self>)
[src]
impl SystemService for SourceActor
[src]
fn start_service(sys: &Arbiter) -> Addr<Self>
[src]
Construct and start system service
fn service_started(&mut self, ctx: &mut Context<Self>)
[src]
Method is called during service initialization.
fn from_registry() -> Addr<Self>
[src]
Get actor's address from system registry
Auto Trait Implementations
impl !Send for SourceActor
impl Unpin for SourceActor
impl !Sync for SourceActor
impl !UnwindSafe for SourceActor
impl !RefUnwindSafe for SourceActor
Blanket Implementations
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
ⓘImportant traits for &'_ mut Wfn borrow_mut(&mut self) -> &mut T
[src]
ⓘImportant traits for &'_ mut W
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Erased for T
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,