Struct Replier 

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

Server-Seite eines DDS-RPC-Service.

Implementations

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

pub fn new( participant: &DomainParticipant, service_name: &str, qos: &RpcQos, handler: Arc<dyn ReplierHandler<TIn, TOut>>, ) -> RpcResult<Self>

Legt einen neuen Replier gegen service_name an.

Errors

Siehe crate::requester::Requester::new.

pub fn with_instance( participant: &DomainParticipant, service_name: &str, instance_name: &str, qos: &RpcQos, handler: Arc<dyn ReplierHandler<TIn, TOut>>, ) -> RpcResult<Self>

Wie Self::new, mit explizitem Instance-Namen.

Errors

Siehe crate::requester::Requester::with_instance.

pub fn service_name(&self) -> &str

Service-Name.

pub fn instance_name(&self) -> &str

Service-Instance-Name.

pub fn handled_count(&self) -> u64

Anzahl bisher erfolgreich verarbeiteter Requests.

pub fn error_count(&self) -> u64

Anzahl Requests, die der Handler mit Err(_) quittiert hat.

pub fn tick(&self) -> usize

Liest pending Requests, ruft den Handler, schreibt Reply zurueck. Liefert die Anzahl der in diesem Tick verarbeiteten Requests.

Trait Implementations

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

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

Formats the value using the given formatter.