[−][src]Struct arcon::prelude::default_components::DeadletterBox
Methods
impl DeadletterBox
[src]
pub fn new(notify_ready: Promise<()>) -> DeadletterBox
[src]
Trait Implementations
impl Actor for DeadletterBox
[src]
fn receive_local(&mut self, sender: ActorRef, msg: &(dyn Any + 'static))
[src]
fn receive_message(
&mut self,
sender: ActorPath,
ser_id: u64,
_buf: &mut dyn Buf
)
[src]
&mut self,
sender: ActorPath,
ser_id: u64,
_buf: &mut dyn Buf
)
impl Provide<ControlPort> for DeadletterBox
[src]
fn handle(&mut self, event: ControlEvent)
[src]
impl ComponentDefinition for DeadletterBox
[src]
fn setup(&mut self, self_component: Arc<Component<DeadletterBox>>)
[src]
fn execute(&mut self, _max_events: usize, _skip: usize) -> ExecuteResult
[src]
fn ctx_mut(&mut self) -> &mut ComponentContext<DeadletterBox>
[src]
fn ctx(&self) -> &ComponentContext<DeadletterBox>
[src]
fn type_name() -> &'static str
[src]
Auto Trait Implementations
impl Send for DeadletterBox
impl Unpin for DeadletterBox
impl !Sync for DeadletterBox
impl !UnwindSafe for DeadletterBox
impl !RefUnwindSafe for DeadletterBox
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,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Erased for T
impl<T> Deserialisable<T> for T
[src]
impl<A> ExecuteSend for A where
A: ActorRaw,
[src]
A: ActorRaw,
fn execute_send(&mut self, env: DispatchEnvelope)
[src]
impl<D> ExecuteSend for D where
D: ActorRaw + Dispatcher,
[src]
D: ActorRaw + Dispatcher,
fn execute_send(&mut self, env: DispatchEnvelope)
[src]
impl<CD> ActorRaw for CD where
CD: Actor,
[src]
CD: Actor,
fn receive(&mut self, env: ReceiveEnvelope)
[src]
impl<CD> ActorRefFactory for CD where
CD: ComponentDefinition + 'static,
[src]
CD: ComponentDefinition + 'static,
impl<CD> Dispatching for CD where
CD: ComponentDefinition + 'static,
[src]
CD: ComponentDefinition + 'static,
fn dispatcher_ref(&self) -> ActorRef
[src]
impl<CD> ActorSource for CD where
CD: ComponentDefinition + 'static,
[src]
CD: ComponentDefinition + 'static,
fn path_resolvable(&self) -> PathResolvable
[src]
impl<CD> Timer<CD> for CD where
CD: ComponentDefinition + 'static,
[src]
CD: ComponentDefinition + 'static,
fn schedule_once<F>(&mut self, timeout: Duration, action: F) -> ScheduledTimer where
F: FnOnce(&mut CD, Uuid) + Send + 'static,
[src]
F: FnOnce(&mut CD, Uuid) + Send + 'static,
fn schedule_periodic<F>(
&mut self,
delay: Duration,
period: Duration,
action: F
) -> ScheduledTimer where
F: Fn(&mut CD, Uuid) + Send + 'static,
[src]
&mut self,
delay: Duration,
period: Duration,
action: F
) -> ScheduledTimer where
F: Fn(&mut CD, Uuid) + Send + 'static,