Struct toad::step::provision_ids::ProvisionIds

pub struct ProvisionIds<P, Inner, SeenIds> { /* private fields */ }

Step responsible for setting the token of all outbound messages with empty ids (Id(0), assumed to be meaningless) with a new id that is guaranteed to be unique to the conversation with the message’s origin/destination address.

For more information, see the module documentation.

Trait Implementations

impl<P: Debug, Inner: Debug, SeenIds: Debug> Debug for ProvisionIds<P, Inner, SeenIds>

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

Formats the value using the given formatter.

impl<P, Inner, SeenIds> Default for ProvisionIds<P, Inner, SeenIds>where Inner: Default, SeenIds: Default,

fn default() -> Self

Returns the “default value” for a type.

impl<P, E: Error, Inner, Ids> Step<P> for ProvisionIds<P, Inner, Ids>where P: PlatformTypes, Inner: Step<P, PollReq = Addrd<Req<P>>, PollResp = Addrd<Resp<P>>, Error = E>, Ids: IdsBySocketAddr<P>,

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 = E

Type of error that can be yielded by poll_req / poll_resp

type Inner = Inner

Inner step that will be performed before this one.

fn inner(&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 before_message_sent( &self, snap: &Snapshot<P>, effs: &mut P::Effects, msg: &mut Addrd<Message<P>> ) -> Result<(), Self::Error>

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

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

Update Observers

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.