subscriber.md

Typed Subscriber

The Subscriber<T> enables you to subscribe to messages of type T on a topic.

Example

use rustecal::pubsub::Subscriber;
use rustecal_types::StringMessage;

let subscriber = Subscriber::<StringMessage>::builder("my_topic").create()?;
subscriber.set_callback(|msg| {
    println!("Received: {}", msg.data());
});