Struct Watching 

pub struct Watching<B: Behavior> { /* private fields */ }

Implementations

impl<B: Behavior> Watching<B>

pub fn new(inner: B, peer: B::Addr, on_stopped: LinkReaction<B>) -> Self

pub fn inner(&self) -> &B

Trait Implementations

impl<B, A, Ph, Sends, Br> Behavior for Watching<B>

where A: Address + Send, Sends: SendAlgebra, Br: BirthMode, B: Behavior<Addr = A, Ph = Ph, Sends = Sends, Birth = Br, Effect = Actions<A, Ph, Sends, Br>, Done = Exit<A>> + Send, B::Event: PeerEvent<B::Addr> + Send, B::Msg: Send,

type Addr = A

type Msg = <B as Behavior>::Msg

type Event = WatchEvent<<B as Behavior>::Event, <B as Behavior>::Addr>

type Sends = SendProduct<Sends, ServiceSends<ObservePeer<A>>>

type Ph = Ph

type Error = <B as Behavior>::Error

type Birth = Br

type Effect = Actions<A, Ph, <Watching<B> as Behavior>::Sends, Br>

type Done = Exit<A>

async fn init(&mut self) -> Result<Self::Effect, B::Error>

async fn step(&mut self, event: Self::Event) -> Result<Self::Effect, B::Error>