Struct async_resol_vbus::TcpClientHandshake

pub struct TcpClientHandshake { /* fields omitted */ }

Handles the client-side of the VBus-over-TCP handshake.

Examples

use async_std::net::{SocketAddr, TcpStream};

use async_resol_vbus::TcpClientHandshake;

let address = "192.168.5.217:7053".parse::<SocketAddr>()?;
let stream = TcpStream::connect(address).await?;
let mut hs = TcpClientHandshake::start(stream).await?;
hs.send_pass_command("vbus").await?;
let stream = hs.send_data_command().await?;
// ...

Methods

impl TcpClientHandshake

pub async fn start(stream: TcpStream) -> Result<TcpClientHandshake>

Start the handshake by waiting for the initial greeting reply from the service.

pub fn into_inner(self) -> TcpStream

Consume self and return the underlying TcpStream.

pub async fn send_connect_command<'_, '_>(
    &'_ mut self,
    via_tag: &'_ str
) -> Result<()>

Send the CONNECT command and wait for the reply.

pub async fn send_pass_command<'_, '_>(
    &'_ mut self,
    password: &'_ str
) -> Result<()>

Send the PASS command and wait for the reply.

pub async fn send_channel_command<'_>(&'_ mut self, channel: u8) -> Result<()>

Send the CHANNEL command and wait for the reply.

pub async fn send_data_command(__arg0: Self) -> Result<TcpStream>

Send the DATA command and wait for the reply.

This function returns the underlying TcpStream since the handshake is complete after sending this command.

pub async fn send_quit_command(__arg0: Self) -> Result<()>

Send the QUIT command and wait for the reply.

Trait Implementations

impl Debug for TcpClientHandshake

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

Formats the value using the given formatter.