Struct RestartSource

Source

pub struct RestartSource;

Expand description

Akka-style restarting source wrapper.

with_backoff restarts when the wrapped source fails or completes. on_failures_with_backoff restarts only on failure. During the backoff the downstream pull is backpressured by waiting on the materializer’s central timer driver; no per-restart timer threads are spawned.

RestartSource

Struct RestartSource Copy item path

Implementations§

impl RestartSource

pub fn with_backoff<Out, Mat, F>( settings: RestartSettings, factory: F, ) -> Source<Out>where Out: Send + 'static, Mat: Send + 'static, F: Fn() -> Source<Out, Mat> + Send + Sync + 'static,

pub fn on_failures_with_backoff<Out, Mat, F>( settings: RestartSettings, factory: F, ) -> Source<Out>where Out: Send + 'static, Mat: Send + 'static, F: Fn() -> Source<Out, Mat> + Send + Sync + 'static,

Auto Trait Implementations§

impl Freeze for RestartSource

impl RefUnwindSafe for RestartSource

impl Send for RestartSource

impl Sync for RestartSource

impl Unpin for RestartSource

impl UnsafeUnpin for RestartSource

impl UnwindSafe for RestartSource

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Message for Twhere T: Any + Send + 'static,

fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>

fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>

impl<T> State for Twhere T: Any + Send + 'static,

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct RestartSource

pub fn with_backoff<Out, Mat, F>( settings: RestartSettings, factory: F, ) -> Source<Out>
where Out: Send + 'static, Mat: Send + 'static, F: Fn() -> Source<Out, Mat> + Send + Sync + 'static,

pub fn on_failures_with_backoff<Out, Mat, F>( settings: RestartSettings, factory: F, ) -> Source<Out>
where Out: Send + 'static, Mat: Send + 'static, F: Fn() -> Source<Out, Mat> + Send + Sync + 'static,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> Message for T
where T: Any + Send + 'static,

impl<T> State for T
where T: Any + Send + 'static,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,