Struct PostRouter 

pub struct PostRouter { /* private fields */ }

Implementations

impl PostRouter

pub fn new() -> Arc<Self>

pub async fn register(&self, id: u64) -> Result<Receiver<PostResponse>>

Registers interest in a post id, enforcing inflight cap.

pub async fn complete(&self, resp: PostResponse)

Completes a waiting caller when a response arrives (releases inflight via Waiter drop).

pub async fn cancel(&self, id: u64)

Cancel a pending id (e.g., timeout); quietly succeed if id wasn’t present.

pub async fn await_with_timeout( &self, id: u64, rx: Receiver<PostResponse>, timeout: Duration, ) -> Result<PostResponse>

Await a response with timeout. On timeout or closed channel, cancels the id.

Trait Implementations

impl Debug for PostRouter

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

Formats the value using the given formatter.

impl Default for PostRouter

fn default() -> Self

Returns the “default value” for a type.