33 releases

new 4.2.1-alpha Apr 18, 2025
0.14.2 Dec 24, 2024
0.13.0 Jul 22, 2024
0.12.1 Nov 10, 2023
0.8.4 Jul 10, 2023

#949 in Network programming

Download history 159/week @ 2024-12-25 25/week @ 2025-01-08 28/week @ 2025-01-22 42/week @ 2025-01-29 33/week @ 2025-02-05 84/week @ 2025-02-12 23/week @ 2025-02-19 27/week @ 2025-02-26 4/week @ 2025-03-05 10/week @ 2025-03-12 8/week @ 2025-03-19 7/week @ 2025-03-26 2/week @ 2025-04-02 329/week @ 2025-04-09

347 downloads per month
Used in 10 crates

MIT license

74KB
1.5K SLoC

Tether Agent for Rust

Create and Connect

Build a Tether Agent using defaults, and connect it automatically:

 let mut agent = TetherAgentOptionsBuilder::new("RustDemoAgent")
        .build()
        .expect("failed to connect Tether");

Send Messages

Create a Channel Sender, passing in a ref to the Tether Agent you created:

    let sender_definition = PlugOptionsBuilder::create_sender("customValues")
        .build(&mut agent)
        .expect("failed to create sender");

If your data structure can be Serialised using serde, go ahead and encode+publish in one step:

#[derive(Serialize)]
#[serde(rename_all = "camelCase")]
struct CustomStruct {
    foo: String,
    bar: f32,
}
/// ...
        let custom_message = CustomStruct {
            foo: "hello".into(),
            bar: 0.42,
        };
        agent
            .encode_and_publish(&sender_definition, custom_message)
            .unwrap();

Or encode first and use agent.send

Receive Messages

Create a Channel Receiver:

    let receiver_defintion = PlugOptionsBuilder::create_input("customValues")
        .build(&mut agent)
        .expect("failed to create receiver");

And check for messages synchronously:

if let Some((topic, payload)) = agent.check_messages() {
  // Always check against the Channel this message "belongs" to!
  if receiver_defintion.matches(&topic) {
      // Decode the message payload, if applicable
      let decoded = rmp_serde::from_slice::<CustomStruct>::(&payload);
      ...
  }

Dependencies

~9–23MB
~326K SLoC