zenobuf-core 0.3.5

A simpler ROS-like framework in Rust with Zenoh transport and Protocol Buffers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! Subscriber implementation for Zenobuf

use crate::error::Result;
use crate::transport;

/// Subscriber for Zenobuf
///
/// A Subscriber is used to receive messages on a topic.
pub struct Subscriber {
    /// Name of the topic
    topic: String,
    /// Inner subscriber implementation
    inner: Box<dyn transport::Subscriber>,
}

impl Subscriber {
    /// Creates a new Subscriber
    pub(crate) fn new(topic: String, inner: Box<dyn transport::Subscriber>) -> Self {
        Self { topic, inner }
    }

    /// Returns the topic name
    pub fn topic(&self) -> &str {
        &self.topic
    }

    /// Closes the subscriber
    pub fn close(&self) -> Result<()> {
        self.inner.close()
    }
}