Struct Requester 

pub struct Requester<TIn: DdsType, TOut: DdsType> { /* private fields */ }

Client-Seite eines DDS-RPC-Service.

TIn ist der User-Request-Payload-Typ (z.B. Calculator_AddRequest), TOut der User-Reply-Payload-Typ. Beide muessen DdsType implementieren — encodet/decodet wird ueber DdsType::encode und DdsType::decode.

Implementations

impl<TIn: DdsType + Send + 'static, TOut: DdsType + Send + 'static> Requester<TIn, TOut>

pub fn new( participant: &DomainParticipant, service_name: &str, qos: &RpcQos, ) -> RpcResult<Self>

Legt einen neuen Requester gegen service_name an.

Erzeugt zwei Topics — <service>_Request (Writer) und <service>_Reply (Reader) — und einen Publisher/Subscriber- Paerchen. instance_name="" heisst “Default-Instance, kein PID_SERVICE_INSTANCE_NAME”.

Errors

• RpcError::InvalidServiceName falls der Name leer/illegal ist.
• RpcError::Dcps bei Topic/Writer/Reader-Anlegen-Fehlern.
• RpcError::DuplicateInstanceName falls auf demselben Participant bereits ein Requester/Replier mit gleichem (service, instance)-Paar laeuft.

pub fn with_instance( participant: &DomainParticipant, service_name: &str, instance_name: &str, qos: &RpcQos, ) -> RpcResult<Self>

Wie Self::new, aber mit explizitem service_instance_name (Spec §7.8.2 PID 0x0080).

Errors

Siehe Self::new.

pub fn service_name(&self) -> &str

Service-Name, gegen den dieser Requester arbeitet.

pub fn instance_name(&self) -> &str

Service-Instance-Name ("" falls Default-Instance).

pub fn pending_count(&self) -> usize

Anzahl outstanding Requests.

pub fn default_timeout(&self) -> Duration

Aktuelle Default-Timeout-Konfiguration.

pub fn send_request_async( &self, payload: &TIn, ) -> RpcResult<(SampleIdentity, Receiver<ReplyOutcome>)>

Schickt einen Request ohne auf Reply zu warten. Liefert einen mpsc::Receiver, ueber den der Caller spaeter mit mpsc::Receiver::recv (oder selbst-getriebener tick()-Schleife) den Reply abholt.

Errors

RpcError::Dcps bei Encoder- oder Writer-Fehlern.

pub fn send_oneway(&self, payload: &TIn) -> RpcResult<SampleIdentity>

Sendet einen Oneway-Request — kein Reply erwartet, kein pending-Slot.

Errors

RpcError::Dcps bei Encoder- oder Writer-Fehlern.

pub fn send_request_blocking( &self, payload: &TIn, timeout: Option<Duration>, ) -> RpcResult<TOut>

Sendet einen Request und blockiert bis Reply oder Timeout.

timeout=None nutzt RpcQos::request_timeout; explizit ueber Some(...) ueberschreiben.

Errors

• RpcError::Timeout wenn waehrend timeout kein Reply ankam.
• RpcError::RemoteException(code) falls Server-Side eine RemoteExceptionCode != Ok zurueckgemeldet hat.
• RpcError::Dcps bei Encode/Decode/Writer-Fehlern.

pub fn tick(&self)

Liest neue Replies aus dem Reader, korreliert via related_request_id, und feuert die zugeordneten mpsc::Sender. Idempotent (kein Reply ⇒ no-op).

Trait Implementations

impl<TIn: DdsType, TOut: DdsType> Debug for Requester<TIn, TOut>

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

Formats the value using the given formatter.