Module tokio 

Tokio-based SRSPP runtime integration. Tokio-based async driver for srspp.

Provides separate sender and receiver types for point-to-point communication.

Sender Example

let sender = SrsppSender::new(config, link);

// Send messages
sender.send(&data).await?;
sender.send(&more_data).await?;

// Wait for all to be acknowledged
sender.flush().await?;

Receiver Example

let mut receiver = SrsppReceiver::new(config, link);

// Receive messages
while let Some(message) = receiver.recv().await? {
    process(message);
}

Structs

DeliveryToken

Zero-copy delivery token returned by SrsppReceiver::wait_for_message.

SrsppReceiver

Async srspp receiver.

SrsppSender

Async srspp sender.

Enums

SrsppError

Error type for srspp operations.