F1Codec

Struct F1Codec 

Source
pub struct F1Codec;
Expand description

Codec to decode UDP packets published by modern F1 games.

This struct implements the Decoder trait for tokio-utils. It can be used to decode incoming UDP packets, and convert them into internal data representations. The F1 codec can decode the packets of all F1 games that are supported by this library.

Trait Implementations§

Source§

impl Decoder for F1Codec

Source§

fn decode(&mut self, src: &mut BytesMut) -> Result<Option<Self::Item>, Error>

Decode a UDP packet and return its data.

The decode method is called whenever a new data frame is received on a UDP socket, and the data frame is passed as an argument. This method has to make a few decisions then:

  1. Does the data form a complete packet so that it can be decoded?
  2. Is the packet a valid packet sent by an F1 game?
  3. Can the packet be parsed?

To answer these questions, the following process is used. First, the packet header is read to determine the game that sent the packet. With the game and the packet type from the header, the expected size of the packet can be determined by calling buffer_size from the FromBytes trait. If the packet is too small, Ok(None) is returned to signal that more data needs to be retrieved from the UDP socket.

If the packet is complete, it is decoded using the from_bytes method in the FromBytes trait. If the packet can be decoded successfully, it is returned. Otherwise, the error from the decoding is returned, signaling that the UDP stream is corrupted and should be shut down.

Source§

type Item = Packet

The type of decoded frames.
Source§

type Error = Error

The type of unrecoverable frame decoding errors. Read more
Source§

fn decode_eof( &mut self, buf: &mut BytesMut, ) -> Result<Option<Self::Item>, Self::Error>

A default method available to be called when there are no more bytes available to be read from the underlying I/O. Read more
Source§

fn framed<T>(self, io: T) -> Framed<T, Self>
where T: AsyncRead + AsyncWrite, Self: Sized,

Provides a Stream and Sink interface for reading and writing to this Io object, using Decode and Encode to read and write the raw data. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.