Struct SimpleRequestResponse

pub struct SimpleRequestResponse { /* private fields */ }

Simple request-response implementation

Implementations

impl SimpleRequestResponse

pub fn new() -> SimpleRequestResponse

Create a new simple request-response component

Trait Implementations

impl Debug for SimpleRequestResponse

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

Formats the value using the given formatter.

impl RequestResponse for SimpleRequestResponse

fn send_request( &self, request: Message, _timeout: Duration, ) -> Result<Message, NerveError>

Send a request and wait for response

fn handle_response( &self, request_id: u64, _response: Message, ) -> Result<(), NerveError>

Handle an incoming response

fn cleanup_expired_requests(&self) -> Result<usize, NerveError>

Clean up expired requests

fn pending_request_count(&self) -> Result<usize, NerveError>

Get pending request count

fn is_request_pending(&self, request_id: u64) -> Result<bool, NerveError>

Check if a request is still pending

fn cancel_request(&self, request_id: u64) -> Result<bool, NerveError>

Cancel a pending request