Enum ShutdownProtocol 

pub enum ShutdownProtocol<E> {
    Behavior(E),
    ShutdownRequested(ShutdownRequested),
}

The complete protocol of a behavior that supports graceful shutdown.

Variants

Behavior(E)

ShutdownRequested(ShutdownRequested)

Trait Implementations

impl<E: Clone> Clone for ShutdownProtocol<E>

fn clone(&self) -> ShutdownProtocol<E>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E: Debug> Debug for ShutdownProtocol<E>

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

Formats the value using the given formatter.

impl<E: Eq> Eq for ShutdownProtocol<E>

impl<E> EventInput<ChildStopped<<E as UserEvent>::Addr>> for ShutdownProtocol<E>

where E: UserEvent + EventInput<ChildStopped<E::Addr>>,

fn inject(event: ChildStopped<E::Addr>) -> Self

impl<E> EventInput<CreationResolved<<<E as UserEvent>::Addr as Address>::Nonce>> for ShutdownProtocol<E>

where E: UserEvent + EventInput<CreationResolved<<E::Addr as Address>::Nonce>>,

fn inject(event: CreationResolved<<E::Addr as Address>::Nonce>) -> Self

impl<E> EventInput<PeerStopped<<E as UserEvent>::Addr>> for ShutdownProtocol<E>

where E: UserEvent + EventInput<PeerStopped<E::Addr>>,

fn inject(event: PeerStopped<E::Addr>) -> Self

impl<E: UserEvent> EventInput<ShutdownRequested> for ShutdownProtocol<E>

fn inject(event: ShutdownRequested) -> Self

impl<E> EventInput<TimerElapsed> for ShutdownProtocol<E>

where E: UserEvent + EventInput<TimerElapsed>,

fn inject(event: TimerElapsed) -> Self

impl<E> EventInput<WorkerCreationResolved<<<E as UserEvent>::Addr as Address>::Nonce>> for ShutdownProtocol<E>

where E: UserEvent + EventInput<WorkerCreationResolved<<E::Addr as Address>::Nonce>>,

fn inject(event: WorkerCreationResolved<<E::Addr as Address>::Nonce>) -> Self

impl<E> EventInput<WorkerStopped<<E as UserEvent>::Addr>> for ShutdownProtocol<E>

where E: UserEvent + EventInput<WorkerStopped<E::Addr>>,

fn inject(event: WorkerStopped<E::Addr>) -> Self

impl<E: PartialEq> PartialEq for ShutdownProtocol<E>

fn eq(&self, other: &ShutdownProtocol<E>) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<E> RouteInput<ChildStopped<<E as UserEvent>::Addr>> for ShutdownProtocol<E>

where E: UserEvent + RouteInput<ChildStopped<E::Addr>>,

fn route(event: ChildStopped<E::Addr>) -> Result<Self, ChildStopped<E::Addr>>

impl<E> RouteInput<CreationResolved<<<E as UserEvent>::Addr as Address>::Nonce>> for ShutdownProtocol<E>

where E: UserEvent + RouteInput<CreationResolved<<E::Addr as Address>::Nonce>>,

fn route( event: CreationResolved<<E::Addr as Address>::Nonce>, ) -> Result<Self, CreationResolved<<E::Addr as Address>::Nonce>>

impl<E> RouteInput<PeerStopped<<E as UserEvent>::Addr>> for ShutdownProtocol<E>

where E: UserEvent + RouteInput<PeerStopped<E::Addr>>,

fn route(event: PeerStopped<E::Addr>) -> Result<Self, PeerStopped<E::Addr>>

impl<E: UserEvent> RouteInput<ShutdownRequested> for ShutdownProtocol<E>

fn route(event: ShutdownRequested) -> Result<Self, ShutdownRequested>

impl<E> RouteInput<TimerElapsed> for ShutdownProtocol<E>

where E: UserEvent + RouteInput<TimerElapsed>,

fn route(event: TimerElapsed) -> Result<Self, TimerElapsed>

impl<E> RouteInput<WorkerCreationResolved<<<E as UserEvent>::Addr as Address>::Nonce>> for ShutdownProtocol<E>

where E: UserEvent + RouteInput<WorkerCreationResolved<<E::Addr as Address>::Nonce>>,

fn route( event: WorkerCreationResolved<<E::Addr as Address>::Nonce>, ) -> Result<Self, WorkerCreationResolved<<E::Addr as Address>::Nonce>>

impl<E> RouteInput<WorkerStopped<<E as UserEvent>::Addr>> for ShutdownProtocol<E>

where E: UserEvent + RouteInput<WorkerStopped<E::Addr>>,

fn route(event: WorkerStopped<E::Addr>) -> Result<Self, WorkerStopped<E::Addr>>

impl<E: PartialEq> StructuralPartialEq for ShutdownProtocol<E>

impl<E: UserEvent> UserEvent for ShutdownProtocol<E>

type Addr = <E as UserEvent>::Addr

type Message = <E as UserEvent>::Message

fn user(from: Self::Addr, message: Self::Message) -> Self

fn into_user(self) -> Result<User<Self::Addr, Self::Message>, Self>

Errors