Struct craftio_rs::CraftReader

pub struct CraftReader<R> { /* fields omitted */ }

Wraps some stream of type R, and implements either CraftSyncReader or CraftAsyncReader (or both) based on what types R implements.

You can construct this type calling the function wrap_with_state, which requires you to specify a packet direction (are written packets server-bound or client-bound?) and a state (handshaking? login? status? play?).

This type holds some internal buffers but only allocates them when they are required.

Implementations

impl<R> CraftReader<R>

pub fn wrap(inner: R, direction: PacketDirection) -> Self

pub fn wrap_with_state(
    inner: R,
    direction: PacketDirection,
    state: State
) -> Self

Trait Implementations

impl<R> CraftAsyncReader for CraftReader<R> where
    R: AsyncReadExact, 

pub fn read_raw_packet_async<'a, 'async_trait, P>(
    &'a mut self
) -> Pin<Box<dyn Future<Output = ReadResult<P>> + Send + 'async_trait>> where
    P: RawPacket<'a>,
    'a: 'async_trait,
    P: 'async_trait,
    Self: 'async_trait, 

pub fn read_raw_untyped_packet_async<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = ReadResult<(Id, &[u8])>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

#[must_use]pub fn read_packet_async<'a, 'async_trait, P>(
    &'a mut self
) -> Pin<Box<dyn Future<Output = ReadResult<<P as RawPacket<'a>>::Packet>> + Send + 'async_trait>> where
    P: RawPacket<'a>,
    'a: 'async_trait,
    P: 'async_trait,
    Self: Send + 'async_trait, 

impl<R> CraftIo for CraftReader<R>

pub fn set_state(&mut self, next: State)

Changes the current connection state. For readers, this changes how numeric packet IDs are interpreted. For writers, this will change the packets that can be written without a panic.

pub fn set_compression_threshold(&mut self, threshold: Option<i32>)

Modifies the compression configuration. If a value of None is provided, then compression is disabled. If a value of Some is provided, then the threshold is set to that value.

pub fn enable_encryption(
    &mut self,
    key: &[u8],
    iv: &[u8]
) -> Result<(), CipherError>

Modifies the encryption configuration. This function should only be called once, and can only be used to enable encryption.

pub fn set_max_packet_size(&mut self, max_size: usize)

Sets the max packet size which this I/O wrapper will decode or transmit.

pub fn ensure_buf_capacity(&mut self, capacity: usize)

pub fn ensure_compression_buf_capacity(&mut self, capacity: usize)

impl<R> CraftSyncReader for CraftReader<R> where
    R: Read, 

pub fn read_raw_packet<'a, P>(&'a mut self) -> ReadResult<P> where
    P: RawPacket<'a>, 

pub fn read_raw_untyped_packet(&mut self) -> ReadResult<(Id, &[u8])>

pub fn read_packet<'a, P>(
    &'a mut self
) -> ReadResult<<P as RawPacket<'a>>::Packet> where
    P: RawPacket<'a>, 

impl<R> CraftWrapper<R> for CraftReader<R>

pub fn into_inner(self) -> R

Unwraps the wrapped value of type I, and drops the wrapper type