Struct SrtSocket 

pub struct SrtSocket { /* private fields */ }

Available on crate feature tokio only.

A handle to an established SRT connection over UDP.

Created by SrtSocket::connect (caller role) or SrtListener::accept (listener role). The protocol itself runs on a background tokio task the handle owns; send enqueues an application payload and recv awaits a delivered one. Dropping the handle aborts the driver task.

Implementations

impl SrtSocket

pub async fn connect<A: ToSocketAddrs>( remote_addr: A, config: HandshakeConfig, ) -> Result<Self>

Connect to a remote SRT peer as a Caller.

pub async fn connect_from<A: ToSocketAddrs>( local_addr: SocketAddr, remote_addr: A, config: HandshakeConfig, ) -> Result<Self>

Connect from a specific local address.

pub async fn send(&mut self, payload: &[u8]) -> Result<()>

Enqueue a payload for transmission to the peer.

Returns immediately once the payload is handed to the driver task — actual transmission, ACK/NAK handling, and retransmission all happen on that task. Fails only if the driver task has stopped (peer shut down or connection error).

pub fn peer_addr(&self) -> SocketAddr

The peer’s socket address.

pub async fn recv(&mut self) -> Result<Option<Vec<u8>>>

Receive the next payload, waiting until one is available. Returns None once the peer has shut down (or the driver task has stopped) and no further payloads will arrive.

Trait Implementations

impl Debug for SrtSocket

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

Formats the value using the given formatter.

impl Drop for SrtSocket

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.