Struct toad::step::handle_acks::HandleAcks
source · pub struct HandleAcks<S, B> { /* private fields */ }
Expand description
Struct responsible for buffering and yielding responses to the request we’re polling for.
For more information, see the module documentation.
Trait Implementations§
source§impl<P: PlatformTypes, B: Map<Addrd<Token>, ()> + Debug, E: Error, S: Step<P, PollReq = Addrd<Req<P>>, PollResp = Addrd<Resp<P>>, Error = E>> Step<P> for HandleAcks<S, B>
impl<P: PlatformTypes, B: Map<Addrd<Token>, ()> + Debug, E: Error, S: Step<P, PollReq = Addrd<Req<P>>, PollResp = Addrd<Resp<P>>, Error = E>> Step<P> for HandleAcks<S, B>
source§fn poll_req(
&self,
snap: &Snapshot<P>,
effects: &mut <P as PlatformTypes>::Effects
) -> StepOutput<Self::PollReq, Self::Error>
fn poll_req( &self, snap: &Snapshot<P>, effects: &mut <P as PlatformTypes>::Effects ) -> StepOutput<Self::PollReq, Self::Error>
Poll for an inbound request Read more
source§fn poll_resp(
&self,
snap: &Snapshot<P>,
effects: &mut <P as PlatformTypes>::Effects,
token: Token,
addr: SocketAddr
) -> StepOutput<Self::PollResp, Self::Error>
fn poll_resp( &self, snap: &Snapshot<P>, effects: &mut <P as PlatformTypes>::Effects, token: Token, addr: SocketAddr ) -> StepOutput<Self::PollResp, Self::Error>
Poll for an inbound response Read more
source§fn on_message_sent(
&self,
snap: &Snapshot<P>,
effects: &mut P::Effects,
msg: &Addrd<Message<P>>
) -> Result<(), Self::Error>
fn on_message_sent( &self, snap: &Snapshot<P>, effects: &mut P::Effects, msg: &Addrd<Message<P>> ) -> Result<(), Self::Error>
Invoked after messages are sent, allowing for internal state change. Read more
Auto Trait Implementations§
impl<S, B> RefUnwindSafe for HandleAcks<S, B>where S: RefUnwindSafe,
impl<S, B> Send for HandleAcks<S, B>where B: Send, S: Send,
impl<S, B> Sync for HandleAcks<S, B>where B: Send + Sync, S: Sync,
impl<S, B> Unpin for HandleAcks<S, B>where B: Unpin, S: Unpin,
impl<S, B> UnwindSafe for HandleAcks<S, B>where S: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<F, A, TF, T> Sequence<F, A, TF> for T
impl<F, A, TF, T> Sequence<F, A, TF> for T
source§fn sequence<Ap>(self) -> <Ap as HKT1>::T<<F as HKT1>::T<A>>where
Self: Sized + Traversable<F, <Ap as HKT1>::T<A>, A, TF> + Foldable<F, <Ap as HKT1>::T<A>>,
Ap: HKT1,
<Ap as HKT1>::T<A>: Applicative<Ap, A> + ApplyOnce<Ap, A>,
<Ap as HKT1>::T<TF>: Applicative<Ap, TF> + ApplyOnce<Ap, TF>,
<Ap as HKT1>::T<<F as HKT1>::T<A>>: Applicative<Ap, <F as HKT1>::T<A>> + ApplyOnce<Ap, <F as HKT1>::T<A>>,
F: HKT1<T<<Ap as HKT1>::T<A>> = Self>,
fn sequence<Ap>(self) -> <Ap as HKT1>::T<<F as HKT1>::T<A>>where Self: Sized + Traversable<F, <Ap as HKT1>::T<A>, A, TF> + Foldable<F, <Ap as HKT1>::T<A>>, Ap: HKT1, <Ap as HKT1>::T<A>: Applicative<Ap, A> + ApplyOnce<Ap, A>, <Ap as HKT1>::T<TF>: Applicative<Ap, TF> + ApplyOnce<Ap, TF>, <Ap as HKT1>::T<<F as HKT1>::T<A>>: Applicative<Ap, <F as HKT1>::T<A>> + ApplyOnce<Ap, <F as HKT1>::T<A>>, F: HKT1<T<<Ap as HKT1>::T<A>> = Self>,
See
Sequence