Struct BufferResponses 

pub struct BufferResponses<S, B> { /* private fields */ }

Struct responsible for buffering and yielding responses to the request we’re polling for.

For more information, see the module documentation.

Trait Implementations

impl<S: Debug, B: Debug> Debug for BufferResponses<S, B>

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

Formats the value using the given formatter.

impl<S: Default, B: Default> Default for BufferResponses<S, B>

fn default() -> Self

Returns the “default value” for a type.

impl<P: PlatformTypes, B: Map<(SocketAddr, Token, Type), Addrd<Resp<P>>>, E: Error, S: Step<P, PollReq = Addrd<Req<P>>, PollResp = Addrd<Resp<P>>, Error = E>> Step<P> for BufferResponses<S, B>

type PollReq = Addrd<Req<P>>

Type that this step returns when polling for a request

type PollResp = Addrd<Resp<P>>

Type that this step returns when polling for a response

type Error = Error<E>

Type of error that can be yielded by poll_req / poll_resp

type Inner = S

Inner step that will be performed before this one.

fn inner(&self) -> &Self::Inner

Get reference to inner step

fn poll_req( &self, snap: &Snapshot<P>, effects: &mut <P as PlatformTypes>::Effects, ) -> StepOutput<Self::PollReq, Self::Error>

Poll for an inbound request

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

fn notify<Path>( &self, path: Path, effects: &mut P::Effects, ) -> Result<(), Self::Error>

where Path: AsRef<str> + Clone,

Update Observers

fn before_message_sent( &self, snap: &Snapshot<P>, effects: &mut <P as PlatformTypes>::Effects, msg: &mut Addrd<Message<P>>, ) -> Result<(), Self::Error>

Invoked before messages are sent, allowing for internal state change & modification.

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.