Struct Connection

struct Connection {
    state: Arc<Mutex<ConnectionState>>,
    socket: Arc<Mutex<TcpStream>>,
    buffer: Mutex<BytesMut>,
}

Object representing a TCP connection.

Fields

state: Arc<Mutex<ConnectionState>>

socket: Arc<Mutex<TcpStream>>

buffer: Mutex<BytesMut>

Implementations

impl Connection

const BUFFER_SIZE: usize = 512usize

Base buffer size and the number of bytes we’re trying to read from the socket.

fn new(socket: TcpStream) -> Self

async fn get_state(&self) -> ConnectionState

Get the current state of the connection

async fn set_state(&self, new_state: ConnectionState)

Change the state of the current Connection.

async fn write<T: AsRef<[u8]>>(&self, data: T) -> Result<(), NetError>

Writes either a &u8 to the socket.

This function can take in Packet.

async fn wait_size(&self, bytes: &[u8]) -> Result<(usize, usize), ()>

Attempts to read a packet size (in bytes, in VarInt). If yes, return size. (prepending the conn buffer) If no, append bytes to connection buffer.

async fn wait_packet( &self, bytes: &[u8], size: usize, size_size: usize, ) -> Result<Packet, ()>

Wait for the number of bytes wait_size() spew. If yes, return packet. (prepending the conn buffer) If no, append bytes to connection buffer.

async fn read(&self) -> Result<Packet, NetError>

TODO: CHECK & REWRITE TODO: CHECK & REWRITE TODO: CHECK & REWRITE TODO: CHECK & REWRITE TODO: CHECK & REWRITE

async fn close(&self) -> Result<(), Error>

Tries to close the connection with the Minecraft client

Trait Implementations

impl Display for Connection

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

Formats the value using the given formatter.