Struct TcpTransport 

pub struct TcpTransport {
    host: String,
    port: u16,
}

Plain TCP transport (unencrypted).

Fields

host: String

port: u16

Implementations

impl TcpTransport

pub fn new(host: impl Into<String>, port: u16) -> Self

Creates a new TCP transport targeting the given host and port.

Trait Implementations

impl Transport for TcpTransport

type Io = TcpStream

The I/O stream type produced by this transport.

async fn connect(&self) -> Result<Self::Io>

Establish a connection to the broker.