Struct IpStackTcpStream 

pub struct IpStackTcpStream { /* private fields */ }

A TCP stream in the IP stack.

This type represents a TCP connection and implements AsyncRead and AsyncWrite for bidirectional data transfer. It handles TCP state management, flow control, and retransmission automatically.

Examples

use ipstack::{IpStack, IpStackConfig, IpStackStream};
use tokio::io::{AsyncReadExt, AsyncWriteExt};

if let IpStackStream::Tcp(mut tcp_stream) = ip_stack.accept().await? {
    println!("New TCP connection from {}", tcp_stream.peer_addr());
     
    // Read data
    let mut buffer = [0u8; 1024];
    let n = tcp_stream.read(&mut buffer).await?;
     
    // Write data
    tcp_stream.write_all(b"HTTP/1.1 200 OK\r\n\r\n").await?;
     
    // Shutdown the stream
    tcp_stream.shutdown().await?;
}

Implementations

impl IpStackTcpStream

pub fn local_addr(&self) -> SocketAddr

Returns the local socket address of the TCP connection.

Examples

let local_addr = tcp_stream.local_addr();
println!("Local address: {}", local_addr);

pub fn peer_addr(&self) -> SocketAddr

Returns the remote socket address of the TCP connection.

Examples

let peer_addr = tcp_stream.peer_addr();
println!("Peer address: {}", peer_addr);

pub fn stream_sender(&self) -> UnboundedSender<NetworkPacket>

Trait Implementations

impl AsyncRead for IpStackTcpStream

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for IpStackTcpStream

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl Debug for IpStackTcpStream

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

Formats the value using the given formatter.

impl Drop for IpStackTcpStream

fn drop(&mut self)

Executes the destructor for this type.