Struct UtpPeerConnection 

pub struct UtpPeerConnection { /* private fields */ }

uTP peer connection wrapper

Wraps a uTP stream for BitTorrent peer communication. Provides the same interface as TCP connections but uses UDP-based uTP protocol.

Implementations

impl UtpPeerConnection

pub fn new( socket: Arc<Mutex<UtpSocket>>, conn_id: u16, info_hash: [u8; 20], ) -> Self

Create a new uTP peer connection

pub async fn connect(addr: SocketAddr, info_hash: &[u8; 20]) -> Result<Self>

Connect to a remote peer via uTP

pub fn conn_id(&self) -> u16

Get the connection ID

pub fn is_connected(&self) -> bool

Check if connection is established

pub async fn perform_handshake(&mut self) -> Result<()>

Perform BitTorrent handshake over uTP

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

Send a BitTorrent message

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

Receive a BitTorrent message

pub async fn close(&mut self) -> Result<()>

Close the connection

pub async fn stats(&self) -> Result<ConnectionStats>

Get connection statistics