Struct AsyncReceiver

pub struct AsyncReceiver<E: Into<Error>, R: AsyncRead<E>, V: MaybeVersioned> { /* private fields */ }

Receives MAVLink frames asynchronously.

Receives MAVLink frames from an instance of AsyncRead.

Implementations

impl<E: Into<Error>, R: AsyncRead<E>> AsyncReceiver<E, R, Versionless>

pub fn new<V: MaybeVersioned>(reader: R) -> AsyncReceiver<E, R, V>

Default constructor.

pub fn versionless(reader: R) -> Self

Create a MAVLink version agnostic receiver.

Creates a protocol-agnostic receiver which will look up for both MAVLink 1 and MAVLink 2 frames.

If you want a receiver restricted to a specific MAVLink protocol version, use AsyncReceiver::versioned.

If you want to instantiate a generic receiver, use AsyncReceiver::new.

pub fn versioned<Version: Versioned>( reader: R, version: Version, ) -> AsyncReceiver<E, R, Version>

Create a receiver specific to a particular MAVLink protocol version.

Same as AsyncReceiver::new::<V1> / AsyncReceiver::new::<V2> but with an explicit version marker as a parameter.

Since versioned receiver will look up for MAVLink frames starting with a specific MavSTX magic byte, it may behave incorrectly, if the incoming stream contains frames of a different protocol version. If this is the case, it is preferred to construct versionless receiver by AsyncReceiver::new and then attempt to convert incoming frames into a specific protocol version with Frame::try_into_versioned.

impl<E: Into<Error>, R: AsyncRead<E>, V: MaybeVersioned> AsyncReceiver<E, R, V>

pub async fn recv(&mut self) -> Result<Frame<V>>

Receives MAVLink Frame.

Blocks until a valid MAVLink frame received.

Versioned receiver accepts only frames of a specific MAVLink protocol version.

Versionless receiver accepts both MAVLink 1 and MAVLink 2 frames.

Trait Implementations

impl<E: Clone + Into<Error>, R: Clone + AsyncRead<E>, V: Clone + MaybeVersioned> Clone for AsyncReceiver<E, R, V>

fn clone(&self) -> AsyncReceiver<E, R, V>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E: Debug + Into<Error>, R: Debug + AsyncRead<E>, V: Debug + MaybeVersioned> Debug for AsyncReceiver<E, R, V>

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

Formats the value using the given formatter.