Struct AsyncDialectConnection 

pub struct AsyncDialectConnection<D> { /* private fields */ }

Available on crate feature tokio only.

A concrete async connection using a dialect.

Trait Implementations

impl<D> AsyncMavConnection<<D as Dialect>::Message> for AsyncDialectConnection<D>

where D: Dialect + Send + Sync, <D as Dialect>::Message: Send + Sync,

async fn recv( &self, ) -> Result<(MavHeader, <D as Dialect>::Message), MessageReadError>

Receive a mavlink message.

async fn recv_raw(&self) -> Result<MAVLinkMessageRaw, MessageReadError>

Receive a raw, unparsed mavlink message.

async fn try_recv( &self, ) -> Result<(MavHeader, <D as Dialect>::Message), MessageReadError>

Receive a MAVLink message without retrying read or parse errors.

async fn send( &self, header: &MavHeader, data: &<D as Dialect>::Message, ) -> Result<usize, MessageWriteError>

Send a mavlink message

async fn send_raw( &self, data: &MAVLinkMessageRaw, ) -> Result<usize, MessageWriteError>

Send a raw, unparsed mavlink message

fn set_protocol_version(&mut self, version: MavlinkVersion)

Sets the MAVLink version to use for receiving (when allow_recv_any_version() is false) and sending messages.

fn protocol_version(&self) -> MavlinkVersion

Gets the currently used MAVLink version

fn set_allow_recv_any_version(&mut self, allow: bool)

Set wether MAVLink messages of either version may be received.

fn allow_recv_any_version(&self) -> bool

Wether messages of any MAVLink version may be received.

fn setup_signing(&mut self, signing_data: Option<SigningConfig>)

Available on crate feature mav2-message-signing only.

Setup secret key used for message signing, or disable message signing.

fn send_frame( &self, frame: &MavFrame<M>, ) -> impl Future<Output = Result<usize, MessageWriteError>> + Send

where M: Message,

Write whole frame.

fn recv_frame( &self, ) -> impl Future<Output = Result<MavFrame<M>, MessageReadError>> + Send

where M: Message,

Read whole frame.

fn send_default( &self, data: &M, ) -> impl Future<Output = Result<usize, MessageWriteError>> + Send

Send a message with default header.